Search Java Classes and Packages
Search Java Frameworks and Libraries
#Org.apache.samza.task Classes and Interfaces - 10 results found.
Name | Description | Type | Package | Framework |
ClosableTask | A 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, | Interface | org.apache.samza.task | Apache Samza |
|
InitableTask | Used as an interface for user processing StreamTasks that need to have specific functionality performed as their StreamTasks are instantiated by TaskRunner. | Interface | org.apache.samza.task | Apache Samza |
|
MessageCollector | Used as an interface for the means of sending message envelopes to an output stream. | Interface | org.apache.samza.task | Apache Samza |
|
StreamTask | A StreamTask is the basic class on which Samza jobs are implemented. | Interface | org.apache.samza.task | Apache Samza |
|
TaskContext | A TaskContext provides resources about the StreamTask, particularly during initialization in an InitableTask and during calls to TaskLifecycleListeners. | Interface | org.apache.samza.task | Apache Samza |
|
TaskCoordinator | TaskCoordinators 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 checkpoints | Interface | org.apache.samza.task | Apache Samza |
|
TaskCoordinator .RequestScope | A task can make requests to the Samza framework while processing messages, such as TaskCoordinator. | Class | org.apache.samza.task.TaskCoordinator | Apache Samza |
|
TaskLifecycleListener | Used to get before/after notifications before initializing/closing all tasks in a given container (JVM/process). | Interface | org.apache.samza.task | Apache Samza |
|
TaskLifecycleListenerFactory | | Interface | org.apache.samza.task | Apache Samza |
|
WindowableTask | Add-on interface to StreamTask implementations to add code which will be run on a specified time interval (via configuration). | Interface | org.apache.samza.task | Apache Samza |