AbstractTask¶
AbstractTask is a base abstraction of the Task abstraction for tasks.
Implementations¶
Creating Instance¶
AbstractTask takes the following to be created:
- TaskId
- ProcessorTopology
- StateDirectory
- ProcessorStateManager
- Input Partitions
- task.timeout.ms configuration property
- Task Type
-
AbstractTaskImplementation
Abstract Class
AbstractTask is an abstract class and cannot be created directly. It is created indirectly for the concrete AbstractTasks.
Input Partitions¶
AbstractTask is given a set of input TopicPartitions to consume and process records from when created and later when updateInputPartitions.