Uses of Interface
org.apache.nemo.runtime.executor.data.DataUtil.IteratorWithNumBytes
-
Packages that use DataUtil.IteratorWithNumBytes Package Description org.apache.nemo.runtime.executor.data org.apache.nemo.runtime.executor.datatransfer -
-
Uses of DataUtil.IteratorWithNumBytes in org.apache.nemo.runtime.executor.data
Classes in org.apache.nemo.runtime.executor.data that implement DataUtil.IteratorWithNumBytes Modifier and Type Class Description static classDataUtil.InputStreamIterator<T>An iterator that emits objects fromInputStreamusing the correspondingDecoderFactory.Methods in org.apache.nemo.runtime.executor.data that return DataUtil.IteratorWithNumBytes Modifier and Type Method Description static <E> DataUtil.IteratorWithNumBytes<E>DataUtil.IteratorWithNumBytes. of(java.util.Iterator<E> innerIterator)Create anDataUtil.IteratorWithNumBytes, with no information about the number of bytes.static <E> DataUtil.IteratorWithNumBytes<E>DataUtil.IteratorWithNumBytes. of(java.util.Iterator<E> innerIterator, long numSerializedBytes, long numEncodedBytes)Create anDataUtil.IteratorWithNumBytes, with the number of bytes in decoded and serialized form.Methods in org.apache.nemo.runtime.executor.data that return types with arguments of type DataUtil.IteratorWithNumBytes Modifier and Type Method Description java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>PipeManagerWorker. read(int srcTaskIndex, RuntimeEdge runtimeEdge, int dstTaskIndex)java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>BlockManagerWorker. readBlock(java.lang.String blockIdWildcard, java.lang.String runtimeEdgeId, ExecutionPropertyMap<EdgeExecutionProperty> edgeProperties, KeyRange keyRange)Inquiries the location of the specific block and routes the request to the local block manager worker or to the lower data plane. -
Uses of DataUtil.IteratorWithNumBytes in org.apache.nemo.runtime.executor.datatransfer
Methods in org.apache.nemo.runtime.executor.datatransfer that return types with arguments of type DataUtil.IteratorWithNumBytes Modifier and Type Method Description java.util.List<java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>>BlockInputReader. read()java.util.List<java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>>InputReader. read()Reads input data depending on the communication pattern of the srcVertex.java.util.List<java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>>PipeInputReader. read()java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>BlockInputReader. retry(int desiredIndex)java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>InputReader. retry(int index)Retry reading input data.java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>PipeInputReader. retry(int index)
-