Package org.apache.nemo.runtime.executor.datatransfer

Class NemoEventEncoderFactory

java.lang.Object

org.apache.nemo.runtime.executor.datatransfer.NemoEventEncoderFactory

All Implemented Interfaces:

java.io.Serializable, EncoderFactory

public final class NemoEventEncoderFactory
extends java.lang.Object
implements EncoderFactory

A factory for NemoEventEncoder.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.nemo.common.coder.EncoderFactory

EncoderFactory.DummyEncoderFactory, EncoderFactory.Encoder<T>

Field Summary

Fields inherited from interface org.apache.nemo.common.coder.EncoderFactory

DUMMY_ENCODER_FACTORY

Constructor Summary

Constructors

Constructor	Description
NemoEventEncoderFactory(EncoderFactory valueEncoderFactory)

Method Summary

Modifier and Type	Method	Description
EncoderFactory.Encoder	create(java.io.OutputStream outputStream)	Get an encoder instance.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NemoEventEncoderFactory

public NemoEventEncoderFactory(EncoderFactory valueEncoderFactory)

Method Detail

create

public EncoderFactory.Encoder create(java.io.OutputStream outputStream)
                              throws java.io.IOException

Description copied from interface: EncoderFactory

Get an encoder instance.

Specified by:

create in interface EncoderFactory

Parameters:

outputStream - the stream on which encoded bytes are written

Returns:

the encoder instance.

Throws:

java.io.IOException - if fail to get the instance.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object