Uses of Package
org.apache.nemo.runtime.executor.data
-
Packages that use org.apache.nemo.runtime.executor.data Package Description org.apache.nemo.runtime.executor org.apache.nemo.runtime.executor.data org.apache.nemo.runtime.executor.data.block org.apache.nemo.runtime.executor.data.partition org.apache.nemo.runtime.executor.data.stores org.apache.nemo.runtime.executor.datatransfer org.apache.nemo.runtime.executor.task org.apache.nemo.runtime.executor.transfer Responsible for transferring block content from one executor to another. -
Classes in org.apache.nemo.runtime.executor.data used by org.apache.nemo.runtime.executor Class Description BroadcastManagerWorker Used by tasks to get/fetch (probably remote) broadcast variables. -
Classes in org.apache.nemo.runtime.executor.data used by org.apache.nemo.runtime.executor.data Class Description BroadcastManagerWorker Used by tasks to get/fetch (probably remote) broadcast variables.DataUtil.IteratorWithNumBytes Iterator
with interface to access to the number of bytes.DataUtil.IteratorWithNumBytes.NumBytesNotSupportedException Exception indicatesDataUtil.IteratorWithNumBytes.getNumSerializedBytes()
orDataUtil.IteratorWithNumBytes.getNumEncodedBytes()
is not supported.MemoryAllocationException An exception to be thrown when a memory allocation operation is not successful.MemoryChunk This class represents chunk of memory residing in off-heap region managed byMemoryPoolAssigner
, which is backed byByteBuffer
.MemoryPoolAssigner The MemoryPoolAssigner assigns the memory that Nemo uses for writing data blocks from theMemoryPoolAssigner.MemoryPool
. -
Classes in org.apache.nemo.runtime.executor.data used by org.apache.nemo.runtime.executor.data.block Class Description FileArea A file area descriptor.MemoryPoolAssigner The MemoryPoolAssigner assigns the memory that Nemo uses for writing data blocks from theMemoryPoolAssigner.MemoryPool
. -
Classes in org.apache.nemo.runtime.executor.data used by org.apache.nemo.runtime.executor.data.partition Class Description DataUtil.IteratorWithNumBytes.NumBytesNotSupportedException Exception indicatesDataUtil.IteratorWithNumBytes.getNumSerializedBytes()
orDataUtil.IteratorWithNumBytes.getNumEncodedBytes()
is not supported.MemoryAllocationException An exception to be thrown when a memory allocation operation is not successful.MemoryChunk This class represents chunk of memory residing in off-heap region managed byMemoryPoolAssigner
, which is backed byByteBuffer
.MemoryPoolAssigner The MemoryPoolAssigner assigns the memory that Nemo uses for writing data blocks from theMemoryPoolAssigner.MemoryPool
. -
Classes in org.apache.nemo.runtime.executor.data used by org.apache.nemo.runtime.executor.data.stores Class Description MemoryPoolAssigner The MemoryPoolAssigner assigns the memory that Nemo uses for writing data blocks from theMemoryPoolAssigner.MemoryPool
.SerializerManager Mapping from RuntimeEdgeId toSerializer
. -
Classes in org.apache.nemo.runtime.executor.data used by org.apache.nemo.runtime.executor.datatransfer Class Description DataUtil.IteratorWithNumBytes Iterator
with interface to access to the number of bytes. -
Classes in org.apache.nemo.runtime.executor.data used by org.apache.nemo.runtime.executor.task Class Description BroadcastManagerWorker Used by tasks to get/fetch (probably remote) broadcast variables. -
Classes in org.apache.nemo.runtime.executor.data used by org.apache.nemo.runtime.executor.transfer Class Description FileArea A file area descriptor.