public interface TaskInfo
TaskId
.
Includes metadata such as whether it's stateful and the names of all state stores
belonging to this task, the set of input topic partitions and changelog topic partitions
for all logged state stores, and the rack ids of all replicas of each topic partition
in the task.Modifier and Type | Method and Description |
---|---|
TaskId |
id() |
boolean |
isStateful() |
Set<String> |
stateStoreNames() |
Set<TaskTopicPartition> |
topicPartitions() |
TaskId id()
TaskId
of the underlying task.boolean isStateful()
Set<String> stateStoreNames()
Set<TaskTopicPartition> topicPartitions()