Uses of Interface
org.apache.nemo.runtime.executor.data.streamchainer.EncodeStreamChainer
-
Packages that use EncodeStreamChainer Package Description org.apache.nemo.runtime.executor.data org.apache.nemo.runtime.executor.data.streamchainer -
-
Uses of EncodeStreamChainer in org.apache.nemo.runtime.executor.data
Method parameters in org.apache.nemo.runtime.executor.data with type arguments of type EncodeStreamChainer Modifier and Type Method Description static java.io.OutputStream
DataUtil. buildOutputStream(java.io.OutputStream out, java.util.List<EncodeStreamChainer> encodeStreamChainers)
ChainOutputStream
withEncodeStreamChainer
s. -
Uses of EncodeStreamChainer in org.apache.nemo.runtime.executor.data.streamchainer
Classes in org.apache.nemo.runtime.executor.data.streamchainer that implement EncodeStreamChainer Modifier and Type Class Description class
CompressionStreamChainer
EncodeStreamChainer
for applying compression.Methods in org.apache.nemo.runtime.executor.data.streamchainer that return types with arguments of type EncodeStreamChainer Modifier and Type Method Description java.util.List<EncodeStreamChainer>
Serializer. getEncodeStreamChainers()
Constructor parameters in org.apache.nemo.runtime.executor.data.streamchainer with type arguments of type EncodeStreamChainer Constructor Description Serializer(EncoderFactory<E> encoderFactory, DecoderFactory<D> decoderFactory, java.util.List<EncodeStreamChainer> encodeStreamChainers, java.util.List<DecodeStreamChainer> decodeStreamChainers)
Constructor.
-