Uses of Interface
org.apache.nemo.common.coder.DecoderFactory
-
-
Uses of DecoderFactory in org.apache.nemo.common.coder
Classes in org.apache.nemo.common.coder that implement DecoderFactory Modifier and Type Class Description class
BytesDecoderFactory
ADecoderFactory
which is used for an array of bytes.static class
DecoderFactory.DummyDecoderFactory
Dummy coder factory implementation which is not supposed to be used.class
IntDecoderFactory
ADecoderFactory
which is used for an integer.class
LongDecoderFactory
ADecoderFactory
which is used for long.class
PairDecoderFactory<A extends java.io.Serializable,B extends java.io.Serializable>
An DecoderFactory forPair
.Fields in org.apache.nemo.common.coder declared as DecoderFactory Modifier and Type Field Description static DecoderFactory
DecoderFactory. DUMMY_DECODER_FACTORY
Dummy coder factory.Methods in org.apache.nemo.common.coder with parameters of type DecoderFactory Modifier and Type Method Description static <A extends java.io.Serializable,B extends java.io.Serializable>
PairDecoderFactory<A,B>PairDecoderFactory. of(DecoderFactory<A> leftDecoderFactory, DecoderFactory<B> rightDecoderFactory)
static initializer of the class. -
Uses of DecoderFactory in org.apache.nemo.common.ir.edge.executionproperty
Methods in org.apache.nemo.common.ir.edge.executionproperty with parameters of type DecoderFactory Modifier and Type Method Description static DecoderProperty
DecoderProperty. of(DecoderFactory value)
Static method exposing the constructor.static KeyDecoderProperty
KeyDecoderProperty. of(DecoderFactory value)
Static method exposing the constructor. -
Uses of DecoderFactory in org.apache.nemo.compiler.frontend.beam.coder
Classes in org.apache.nemo.compiler.frontend.beam.coder that implement DecoderFactory Modifier and Type Class Description class
BeamDecoderFactory<T>
DecoderFactory
fromCoder
. -
Uses of DecoderFactory in org.apache.nemo.runtime.executor.data
Methods in org.apache.nemo.runtime.executor.data with parameters of type DecoderFactory Modifier and Type Method Description void
SerializerManager. register(java.lang.String runtimeEdgeId, EncoderFactory encoderFactory, DecoderFactory decoderFactory)
Register a encoderFactory for runtime edge.void
SerializerManager. register(java.lang.String runtimeEdgeId, EncoderFactory encoderFactory, DecoderFactory decoderFactory, CompressionProperty.Value compressionProperty, CompressionProperty.Value decompressionProperty)
Register a encoderFactory for runtime edge. -
Uses of DecoderFactory in org.apache.nemo.runtime.executor.data.streamchainer
Methods in org.apache.nemo.runtime.executor.data.streamchainer that return DecoderFactory Modifier and Type Method Description DecoderFactory<D>
Serializer. getDecoderFactory()
Constructors in org.apache.nemo.runtime.executor.data.streamchainer with parameters of type DecoderFactory Constructor Description Serializer(EncoderFactory<E> encoderFactory, DecoderFactory<D> decoderFactory, java.util.List<EncodeStreamChainer> encodeStreamChainers, java.util.List<DecodeStreamChainer> decodeStreamChainers)
Constructor. -
Uses of DecoderFactory in org.apache.nemo.runtime.executor.datatransfer
Classes in org.apache.nemo.runtime.executor.datatransfer that implement DecoderFactory Modifier and Type Class Description class
NemoEventDecoderFactory
A factory for NemoEventDecoder.Constructors in org.apache.nemo.runtime.executor.datatransfer with parameters of type DecoderFactory Constructor Description NemoEventDecoderFactory(DecoderFactory valueDecoderFactory)
-