Uses of Interface
org.apache.nemo.runtime.executor.data.streamchainer.DecodeStreamChainer
-
Packages that use DecodeStreamChainer Package Description org.apache.nemo.runtime.executor.data org.apache.nemo.runtime.executor.data.streamchainer -
-
Uses of DecodeStreamChainer in org.apache.nemo.runtime.executor.data
Method parameters in org.apache.nemo.runtime.executor.data with type arguments of type DecodeStreamChainer Modifier and Type Method Description static java.io.InputStream
DataUtil. buildInputStream(java.io.InputStream in, java.util.List<DecodeStreamChainer> decodeStreamChainers)
ChainInputStream
withDecodeStreamChainer
s. -
Uses of DecodeStreamChainer in org.apache.nemo.runtime.executor.data.streamchainer
Classes in org.apache.nemo.runtime.executor.data.streamchainer that implement DecodeStreamChainer Modifier and Type Class Description class
DecompressionStreamChainer
DecodeStreamChainer
for applying compression.Methods in org.apache.nemo.runtime.executor.data.streamchainer that return types with arguments of type DecodeStreamChainer Modifier and Type Method Description java.util.List<DecodeStreamChainer>
Serializer. getDecodeStreamChainers()
-