An AsyncStreamTask is the basic class to support multithreading execution in Samza container.
A ClosableTask augments
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 callback that is invoked when its corresponding timer registered via
Add-on interface to