Uses of Class
org.apache.nemo.runtime.executor.data.partition.NonSerializedPartition

Packages that use NonSerializedPartition

Package	Description
org.apache.nemo.runtime.executor.data
org.apache.nemo.runtime.executor.data.block

Uses of NonSerializedPartition in org.apache.nemo.runtime.executor.data

Methods in org.apache.nemo.runtime.executor.data that return NonSerializedPartition

Modifier and Type	Method	Description
static <K extends java.io.Serializable> NonSerializedPartition	DataUtil.deserializePartition(int partitionSize, Serializer serializer, K key, java.io.InputStream inputStream)	Reads the data of a partition from an input stream and deserializes it.

Methods in org.apache.nemo.runtime.executor.data that return types with arguments of type NonSerializedPartition

Modifier and Type	Method	Description
static <K extends java.io.Serializable> java.lang.Iterable<NonSerializedPartition<K>>	DataUtil.convertToNonSerPartitions(Serializer serializer, java.lang.Iterable<SerializedPartition<K>> partitionsToConvert)	Converts the serialized Partitions in an iterable to non-serialized partitions.

Method parameters in org.apache.nemo.runtime.executor.data with type arguments of type NonSerializedPartition

Modifier and Type	Method	Description
static java.lang.Iterable	DataUtil.concatNonSerPartitions(java.lang.Iterable<NonSerializedPartition> partitionsToConcat)	Concatenates an iterable of non-serialized Partitions into a single iterable of elements.
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-serialized Partitions in an iterable to serialized partitions.

Uses of NonSerializedPartition in org.apache.nemo.runtime.executor.data.block

Methods in org.apache.nemo.runtime.executor.data.block that return types with arguments of type NonSerializedPartition

Modifier and Type	Method	Description
java.lang.Iterable<NonSerializedPartition<K>>	Block.readPartitions(KeyRange<K> keyRange)	Retrieves the NonSerializedPartitions in a specific key range from this block.
java.lang.Iterable<NonSerializedPartition<K>>	FileBlock.readPartitions(KeyRange keyRange)	Retrieves the partitions of this block from the file in a specific key range and deserializes it.
java.lang.Iterable<NonSerializedPartition<K>>	NonSerializedMemoryBlock.readPartitions(KeyRange keyRange)	Retrieves the NonSerializedPartitions in a specific hash range from this block.
java.lang.Iterable<NonSerializedPartition<K>>	SerializedMemoryBlock.readPartitions(KeyRange keyRange)	Retrieves the NonSerializedPartitions in a specific hash range from this block.

Method parameters in org.apache.nemo.runtime.executor.data.block with type arguments of type NonSerializedPartition

Modifier and Type	Method	Description
void	Block.writePartitions(java.lang.Iterable<NonSerializedPartition<K>> partitions)	Stores NonSerializedPartitions to this block.
void	FileBlock.writePartitions(java.lang.Iterable<NonSerializedPartition<K>> partitions)	Writes NonSerializedPartitions to this block.
void	NonSerializedMemoryBlock.writePartitions(java.lang.Iterable<NonSerializedPartition<K>> partitions)	Stores NonSerializedPartitions to this block.
void	SerializedMemoryBlock.writePartitions(java.lang.Iterable<NonSerializedPartition<K>> partitions)	Serialized and stores NonSerializedPartitions to this block.