A ClosableTask 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.
Used to get before/after notifications before initializing/closing all tasks in a given container (JVM/process).
Add-on interface to