An AsyncStreamTask is the basic class to support multithreading execution in Samza container.
The EndOfStreamListenerTask augments
Used as an interface for user processing StreamTasks that need to have specific functionality performed as their StreamTasks are instantiated by TaskRunner.
Used as an interface for the means of sending message envelopes to an output stream.
A StreamTask is the basic class on which Samza jobs are implemented.
A TaskCallback is fired by a
TaskCoordinators are provided to the process methods of
The base interface for all task factories (i.e.
Add-on interface to