ReaderBase (Flink : 2.0-SNAPSHOT API)

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`boolean`	`hasReachedEndOfSuperstep()`
`boolean`	`isFinished()` Returns whether the reader has consumed the input.
`void`	`registerTaskEventListener(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)`
`void`	`sendTaskEvent(TaskEvent event)`
`void`	`setIterativeReader()`
`void`	`startNextSuperstep()`

isFinished
```
boolean isFinished()
```
Returns whether the reader has consumed the input.

void sendTaskEvent(TaskEvent event)
            throws IOException

void registerTaskEventListener(EventListener<TaskEvent> listener,
                               Class<? extends TaskEvent> eventType)

Back to Flink Website