Class PipeInputReader
- java.lang.Object
-
- org.apache.nemo.runtime.executor.datatransfer.PipeInputReader
-
- All Implemented Interfaces:
InputReader
public final class PipeInputReader extends java.lang.Object implements InputReader
Represents the input data transfer to a task.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ExecutionPropertyMap<EdgeExecutionProperty>
getProperties()
IRVertex
getSrcIrVertex()
java.util.List<java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>>
read()
Reads input data depending on the communication pattern of the srcVertex.java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>
retry(int index)
Retry reading input data.
-
-
-
Method Detail
-
read
public java.util.List<java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>> read()
Description copied from interface:InputReader
Reads input data depending on the communication pattern of the srcVertex.- Specified by:
read
in interfaceInputReader
- Returns:
- the list of iterators.
-
retry
public java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes> retry(int index)
Description copied from interface:InputReader
Retry reading input data.- Specified by:
retry
in interfaceInputReader
- Parameters:
index
- of the failed iterator in the list returned by read().- Returns:
- the retried iterator.
-
getProperties
public ExecutionPropertyMap<EdgeExecutionProperty> getProperties()
- Specified by:
getProperties
in interfaceInputReader
-
getSrcIrVertex
public IRVertex getSrcIrVertex()
- Specified by:
getSrcIrVertex
in interfaceInputReader
-
-