Uses of Class
org.apache.nemo.runtime.executor.data.streamchainer.Serializer

Packages that use Serializer

Package	Description
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.transfer	Responsible for transferring block content from one executor to another.

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

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

Modifier and Type	Method	Description
Serializer	PipeManagerWorker.getSerializer(java.lang.String runtimeEdgeId)
Serializer	SerializerManager.getSerializer(java.lang.String runtimeEdgeId)	Return the serializer for the specified runtime edge.

Methods in org.apache.nemo.runtime.executor.data with parameters of type Serializer

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.
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.
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.

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

Constructors in org.apache.nemo.runtime.executor.data.block with parameters of type Serializer

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 Serializer in org.apache.nemo.runtime.executor.data.partition

Constructors in org.apache.nemo.runtime.executor.data.partition with parameters of type Serializer

Constructor	Description
SerializedPartition(K key, Serializer serializer, MemoryPoolAssigner memoryPoolAssigner)	Creates a serialized Partition without actual data.

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

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

Modifier and Type	Method	Description
void	ByteOutputContext.ByteOutputStream.writeElement(java.lang.Object element, Serializer serializer)	Write an element to the channel.
void	TransferOutputStream.writeElement(java.lang.Object element, Serializer serializer)	Write an element into the output stream.