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

Class SerializerManager

java.lang.Object

org.apache.nemo.runtime.executor.data.SerializerManager

public final class SerializerManager
extends java.lang.Object

Mapping from RuntimeEdgeId to Serializer.

Method Summary

Modifier and Type	Method	Description
Serializer	getSerializer(java.lang.String runtimeEdgeId)	Return the serializer for the specified runtime edge.
void	register(java.lang.String runtimeEdgeId, EncoderFactory encoderFactory, DecoderFactory decoderFactory)	Register a encoderFactory for runtime edge.
void	register(java.lang.String runtimeEdgeId, EncoderFactory encoderFactory, DecoderFactory decoderFactory, CompressionProperty.Value compressionProperty, CompressionProperty.Value decompressionProperty)	Register a encoderFactory for runtime edge.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

register

public void register(java.lang.String runtimeEdgeId,
                     EncoderFactory encoderFactory,
                     DecoderFactory decoderFactory)

Register a encoderFactory for runtime edge. This method regards that compression and decompression property are empty.

Parameters:

runtimeEdgeId - id of the runtime edge.

encoderFactory - the corresponding encoder factory.

decoderFactory - the corresponding decoder factory.

register

public void register(java.lang.String runtimeEdgeId,
                     EncoderFactory encoderFactory,
                     DecoderFactory decoderFactory,
                     @Nullable
                     CompressionProperty.Value compressionProperty,
                     @Nullable
                     CompressionProperty.Value decompressionProperty)

Register a encoderFactory for runtime edge.

Parameters:

runtimeEdgeId - id of the runtime edge.

encoderFactory - the corresponding encoder factory.

decoderFactory - the corresponding decoder factory.

compressionProperty - compression property, or null not to enable compression

decompressionProperty - decompression property, or null not to enable decompression

getSerializer

public Serializer getSerializer(java.lang.String runtimeEdgeId)

Return the serializer for the specified runtime edge.

Parameters:

runtimeEdgeId - id of the runtime edge.

Returns:

the corresponding serializer.