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

Packages that use SerializedPartition

Package	Description
org.apache.nemo.runtime.executor.data
org.apache.nemo.runtime.executor.data.block
org.apache.nemo.runtime.executor.transfer	Responsible for transferring block content from one executor to another.

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

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

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-serialized Partitions in an iterable to serialized partitions.

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

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.

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

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

Modifier and Type	Method	Description
java.lang.Iterable<SerializedPartition<K>>	Block.readSerializedPartitions(KeyRange<K> keyRange)	Retrieves the SerializedPartitions in a specific key range.
java.lang.Iterable<SerializedPartition<K>>	FileBlock.readSerializedPartitions(KeyRange keyRange)	Retrieves the SerializedPartitions in a specific key range.
java.lang.Iterable<SerializedPartition<K>>	NonSerializedMemoryBlock.readSerializedPartitions(KeyRange keyRange)	Retrieves the SerializedPartitions in a specific hash range.
java.lang.Iterable<SerializedPartition<K>>	SerializedMemoryBlock.readSerializedPartitions(KeyRange keyRange)	Retrieves the SerializedPartitions in a specific hash range.

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

Modifier and Type	Method	Description
void	Block.writeSerializedPartitions(java.lang.Iterable<SerializedPartition<K>> partitions)	Stores SerializedPartitions to this block.
void	FileBlock.writeSerializedPartitions(java.lang.Iterable<SerializedPartition<K>> partitions)	Writes SerializedPartitions to this block.
void	NonSerializedMemoryBlock.writeSerializedPartitions(java.lang.Iterable<SerializedPartition<K>> partitions)	Stores SerializedPartitions to this block.
void	SerializedMemoryBlock.writeSerializedPartitions(java.lang.Iterable<SerializedPartition<K>> partitions)	Stores SerializedPartitions to this block.

Uses of SerializedPartition in org.apache.nemo.runtime.executor.transfer

Methods in org.apache.nemo.runtime.executor.transfer with parameters of type SerializedPartition

Modifier and Type	Method	Description
ByteOutputContext.ByteOutputStream	ByteOutputContext.ByteOutputStream.writeSerializedPartitionBuffer(SerializedPartition serializedPartition, boolean releaseOnComplete)	Writes SerializedPartition.