Uses of Interface
org.apache.nemo.common.coder.EncoderFactory
-
-
Uses of EncoderFactory in org.apache.nemo.common.coder
Classes in org.apache.nemo.common.coder that implement EncoderFactory Modifier and Type Class Description class
BytesEncoderFactory
AEncoderFactory
which is used for an array of bytes.static class
EncoderFactory.DummyEncoderFactory
Dummy encoder factory implementation which is not supposed to be used.class
IntEncoderFactory
AEncoderFactory
which is used for an integer.class
LongEncoderFactory
AEncoderFactory
which is used for long.class
PairEncoderFactory<A extends java.io.Serializable,B extends java.io.Serializable>
An EncoderFactory forPair
.Fields in org.apache.nemo.common.coder declared as EncoderFactory Modifier and Type Field Description static EncoderFactory
EncoderFactory. DUMMY_ENCODER_FACTORY
Dummy encoder factory.Methods in org.apache.nemo.common.coder with parameters of type EncoderFactory Modifier and Type Method Description static <A extends java.io.Serializable,B extends java.io.Serializable>
PairEncoderFactory<A,B>PairEncoderFactory. of(EncoderFactory<A> leftEncoderFactory, EncoderFactory<B> rightEncoderFactory)
static initializer of the class. -
Uses of EncoderFactory in org.apache.nemo.common.ir.edge.executionproperty
Methods in org.apache.nemo.common.ir.edge.executionproperty with parameters of type EncoderFactory Modifier and Type Method Description static EncoderProperty
EncoderProperty. of(EncoderFactory value)
Static method exposing the constructor.static KeyEncoderProperty
KeyEncoderProperty. of(EncoderFactory value)
Static method exposing the constructor. -
Uses of EncoderFactory in org.apache.nemo.compiler.frontend.beam.coder
Classes in org.apache.nemo.compiler.frontend.beam.coder that implement EncoderFactory Modifier and Type Class Description class
BeamEncoderFactory<T>
EncoderFactory
fromCoder
. -
Uses of EncoderFactory in org.apache.nemo.runtime.executor.data
Methods in org.apache.nemo.runtime.executor.data with parameters of type EncoderFactory 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 EncoderFactory in org.apache.nemo.runtime.executor.data.streamchainer
Methods in org.apache.nemo.runtime.executor.data.streamchainer that return EncoderFactory Modifier and Type Method Description EncoderFactory<E>
Serializer. getEncoderFactory()
Constructors in org.apache.nemo.runtime.executor.data.streamchainer with parameters of type EncoderFactory Constructor Description Serializer(EncoderFactory<E> encoderFactory, DecoderFactory<D> decoderFactory, java.util.List<EncodeStreamChainer> encodeStreamChainers, java.util.List<DecodeStreamChainer> decodeStreamChainers)
Constructor. -
Uses of EncoderFactory in org.apache.nemo.runtime.executor.datatransfer
Classes in org.apache.nemo.runtime.executor.datatransfer that implement EncoderFactory Modifier and Type Class Description class
NemoEventEncoderFactory
A factory for NemoEventEncoder.Constructors in org.apache.nemo.runtime.executor.datatransfer with parameters of type EncoderFactory Constructor Description NemoEventEncoderFactory(EncoderFactory valueEncoderFactory)
-