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

Class Serializer<E,D>

java.lang.Object

org.apache.nemo.runtime.executor.data.streamchainer.Serializer<E,D>

Type Parameters:

E - encoderFactory element type.

D - decoderFactory element type.

public final class Serializer<E,D>
extends java.lang.Object

class that contains EncoderFactory, DecoderFactory and List of EncodeStreamChainer.

Constructor Summary

Constructors

Constructor	Description
Serializer(EncoderFactory<E> encoderFactory, DecoderFactory<D> decoderFactory, java.util.List<EncodeStreamChainer> encodeStreamChainers, java.util.List<DecodeStreamChainer> decodeStreamChainers)	Constructor.

Method Summary

Modifier and Type	Method	Description
DecoderFactory<D>	getDecoderFactory()
java.util.List<DecodeStreamChainer>	getDecodeStreamChainers()
EncoderFactory<E>	getEncoderFactory()
java.util.List<EncodeStreamChainer>	getEncodeStreamChainers()

Methods inherited from class java.lang.Object

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

Constructor Detail

Serializer

public Serializer(EncoderFactory<E> encoderFactory,
                  DecoderFactory<D> decoderFactory,
                  java.util.List<EncodeStreamChainer> encodeStreamChainers,
                  java.util.List<DecodeStreamChainer> decodeStreamChainers)

Constructor.

Parameters:

encoderFactory - EncoderFactory.

decoderFactory - DecoderFactory.

encodeStreamChainers - the list of EncodeStreamChainer to use for encoding.

decodeStreamChainers - the list of DecodeStreamChainer to use for decoding.

Method Detail

getEncoderFactory

public EncoderFactory<E> getEncoderFactory()

Returns:

the EncoderFactory to use.

getDecoderFactory

public DecoderFactory<D> getDecoderFactory()

Returns:

the DecoderFactory to use.

getEncodeStreamChainers

public java.util.List<EncodeStreamChainer> getEncodeStreamChainers()

Returns:

the list of EncodeStreamChainer for encoding.

getDecodeStreamChainers

public java.util.List<DecodeStreamChainer> getDecodeStreamChainers()

Returns:

the list of EncodeStreamChainer for decoding.