Interface ReaderBase
-
- All Known Subinterfaces:
MutableReader<T>
,Reader<T>
- All Known Implementing Classes:
AbstractReader
,MutableRecordReader
,RecordReader
public interface ReaderBase
The basic API for every reader.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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()
-
-
-
Method Detail
-
isFinished
boolean isFinished()
Returns whether the reader has consumed the input.
-
sendTaskEvent
void sendTaskEvent(TaskEvent event) throws IOException
- Throws:
IOException
-
registerTaskEventListener
void registerTaskEventListener(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)
-
setIterativeReader
void setIterativeReader()
-
startNextSuperstep
void startNextSuperstep()
-
hasReachedEndOfSuperstep
boolean hasReachedEndOfSuperstep()
-
-