public class TaskManager
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
java.util.Set<TaskId> |
cachedTasksIds()
Returns ids of tasks whose states are kept on the local storage.
|
java.util.Set<TaskId> |
prevActiveTaskIds() |
java.util.UUID |
processId() |
void |
setAssignmentMetadata(java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> activeTasks,
java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks) |
void |
setClusterMetadata(org.apache.kafka.common.Cluster cluster) |
void |
setPartitionsByHostState(java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHostState) |
java.lang.String |
toString()
Produces a string representation containing useful information about the TaskManager.
|
java.lang.String |
toString(java.lang.String indent) |
void |
updateSubscriptionsFromAssignment(java.util.List<org.apache.kafka.common.TopicPartition> partitions) |
void |
updateSubscriptionsFromMetadata(java.util.Set<java.lang.String> topics) |
public java.util.Set<TaskId> prevActiveTaskIds()
public java.util.Set<TaskId> cachedTasksIds()
public java.util.UUID processId()
public void setClusterMetadata(org.apache.kafka.common.Cluster cluster)
public void setPartitionsByHostState(java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHostState)
public void setAssignmentMetadata(java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> activeTasks, java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks)
public void updateSubscriptionsFromAssignment(java.util.List<org.apache.kafka.common.TopicPartition> partitions)
public void updateSubscriptionsFromMetadata(java.util.Set<java.lang.String> topics)
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String toString(java.lang.String indent)