Uses of Class
org.apache.nemo.runtime.executor.data.MemoryPoolAssigner
-
-
Uses of MemoryPoolAssigner in org.apache.nemo.runtime.executor.data
Methods in org.apache.nemo.runtime.executor.data with parameters of type MemoryPoolAssigner Modifier and Type Method Description static <K extends java.io.Serializable>
java.lang.Iterable<SerializedPartition<K>>DataUtil. convertToSerPartitions(Serializer serializer, java.lang.Iterable<NonSerializedPartition<K>> partitionsToConvert, MemoryPoolAssigner memoryPoolAssigner)
Converts the non-serializedPartition
s in an iterable to serialized partitions.Constructors in org.apache.nemo.runtime.executor.data with parameters of type MemoryPoolAssigner Constructor Description DirectByteBufferOutputStream(MemoryPoolAssigner memoryPoolAssigner)
Default constructor. -
Uses of MemoryPoolAssigner in org.apache.nemo.runtime.executor.data.block
Constructors in org.apache.nemo.runtime.executor.data.block with parameters of type MemoryPoolAssigner Constructor Description FileBlock(java.lang.String blockId, Serializer serializer, java.lang.String filePath, FileMetadata<K> metadata, MemoryPoolAssigner memoryPoolAssigner)
Constructor.NonSerializedMemoryBlock(java.lang.String blockId, Serializer serializer, MemoryPoolAssigner memoryPoolAssigner)
Constructor.SerializedMemoryBlock(java.lang.String blockId, Serializer serializer, MemoryPoolAssigner memoryPoolAssigner)
Constructor. -
Uses of MemoryPoolAssigner in org.apache.nemo.runtime.executor.data.partition
Constructors in org.apache.nemo.runtime.executor.data.partition with parameters of type MemoryPoolAssigner Constructor Description SerializedPartition(K key, byte[] serializedData, int length, MemoryPoolAssigner memoryPoolAssigner)
Creates a serializedPartition
with actual data residing in on-heap region.SerializedPartition(K key, java.util.List<MemoryChunk> serializedChunkList, int length, MemoryPoolAssigner memoryPoolAssigner)
Creates a serializedPartition
with actual data residing in off-heap region.SerializedPartition(K key, Serializer serializer, MemoryPoolAssigner memoryPoolAssigner)
Creates a serializedPartition
without actual data. -
Uses of MemoryPoolAssigner in org.apache.nemo.runtime.executor.data.stores
Constructors in org.apache.nemo.runtime.executor.data.stores with parameters of type MemoryPoolAssigner Constructor Description LocalBlockStore(SerializerManager coderManager, MemoryPoolAssigner memoryPoolAssigner)
Constructor.
-