Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Org.apache.samza.task Classes and Interfaces - 10 results found.
NameDescriptionTypePackageFramework
ClosableTaskA ClosableTask augments StreamTask, allowing the method implementer to specify code that will be called when the StreamTask is being shut down by the framework, providing to emit final metrics,Interfaceorg.apache.samza.taskApache Samza
InitableTaskUsed as an interface for user processing StreamTasks that need to have specific functionality performed as their StreamTasks are instantiated by TaskRunner.Interfaceorg.apache.samza.taskApache Samza
MessageCollectorUsed as an interface for the means of sending message envelopes to an output stream.Interfaceorg.apache.samza.taskApache Samza
StreamTaskA StreamTask is the basic class on which Samza jobs are implemented.Interfaceorg.apache.samza.taskApache Samza
TaskContextA TaskContext provides resources about the StreamTask, particularly during initialization in an InitableTask and during calls to TaskLifecycleListeners.Interfaceorg.apache.samza.taskApache Samza
TaskCoordinatorTaskCoordinators are provided to the process methods of StreamTask implementations to allow the user code to request actions from the Samza framework, including committing the current checkpointsInterfaceorg.apache.samza.taskApache Samza
TaskCoordinator .RequestScopeA task can make requests to the Samza framework while processing messages, such as TaskCoordinator.Classorg.apache.samza.task.TaskCoordinatorApache Samza
TaskLifecycleListenerUsed to get before/after notifications before initializing/closing all tasks in a given container (JVM/process).Interfaceorg.apache.samza.taskApache Samza
TaskLifecycleListenerFactoryInterfaceorg.apache.samza.taskApache Samza
WindowableTaskAdd-on interface to StreamTask implementations to add code which will be run on a specified time interval (via configuration).Interfaceorg.apache.samza.taskApache Samza