BlockInputReader (Nemo Project 0.4 API)

java.lang.Object
- org.apache.nemo.runtime.executor.datatransfer.BlockInputReader

All Implemented Interfaces:: InputReader

public final class BlockInputReader
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 desiredIndex)`	Retry reading input data.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 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 interface InputReader
    
    Returns:
    
    the list of iterators.
  - retry
```
public java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes> retry(int desiredIndex)
```
    Description copied from interface: InputReader
    
    Retry reading input data.
    
    Specified by:
    
    retry in interface InputReader
    
    Parameters:
    
    desiredIndex - of the failed iterator in the list returned by read().
    
    Returns:
    
    the retried iterator.
  - getSrcIrVertex
```
public IRVertex getSrcIrVertex()
```
    Specified by:
    
    getSrcIrVertex in interface InputReader
  - getProperties
```
public ExecutionPropertyMap<EdgeExecutionProperty> getProperties()
```
    Specified by:
    
    getProperties in interface InputReader