public interface EndOfStreamListenerTask
StreamTaskallowing the method implementor to specify code to be executed when the 'end-of-stream' is reached for all input SSPs. While some streaming sources are infinite (like kafka), some others like HDFS, File based sources are bounded. For instance, file based sources have the notion of EOF to indicate that there is no more data.
void onEndOfStream(MessageCollector collector, TaskCoordinator coordinator) throws java.lang.Exception
TaskCoordinatorto commit changes.
collector- Contains the means of sending message envelopes to an output stream.*
coordinator- Manages execution of tasks.
java.lang.Exception- Any exception types encountered during the execution of the processing task.