Class BeamDecoderFactory<T>
- java.lang.Object
-
- org.apache.nemo.compiler.frontend.beam.coder.BeamDecoderFactory<T>
-
- Type Parameters:
T
- the type of element to decode.
- All Implemented Interfaces:
java.io.Serializable
,DecoderFactory<T>
public final class BeamDecoderFactory<T> extends java.lang.Object implements DecoderFactory<T>
DecoderFactory
fromCoder
.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.nemo.common.coder.DecoderFactory
DecoderFactory.Decoder<T>, DecoderFactory.DummyDecoderFactory
-
-
Field Summary
-
Fields inherited from interface org.apache.nemo.common.coder.DecoderFactory
DUMMY_DECODER_FACTORY
-
-
Constructor Summary
Constructors Constructor Description BeamDecoderFactory(org.apache.beam.sdk.coders.Coder<T> beamCoder)
Constructor of BeamDecoderFactory.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DecoderFactory.Decoder<T>
create(java.io.InputStream inputStream)
Get a decoder instance.java.lang.String
toString()
-
-
-
Constructor Detail
-
BeamDecoderFactory
public BeamDecoderFactory(org.apache.beam.sdk.coders.Coder<T> beamCoder)
Constructor of BeamDecoderFactory.- Parameters:
beamCoder
- actual Beam coder to use.
-
-
Method Detail
-
create
public DecoderFactory.Decoder<T> create(java.io.InputStream inputStream)
Description copied from interface:DecoderFactory
Get a decoder instance.- Specified by:
create
in interfaceDecoderFactory<T>
- Parameters:
inputStream
- the input stream to decode.- Returns:
- the decoder instance.
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-