Class TaskManager


  • public class TaskManager
    extends java.lang.Object
    • Method Detail

      • prevActiveTaskIds

        public java.util.Set<TaskId> prevActiveTaskIds()
      • cachedTasksIds

        public java.util.Set<TaskId> cachedTasksIds()
        Returns ids of tasks whose states are kept on the local storage.
      • processId

        public java.util.UUID processId()
      • setClusterMetadata

        public void setClusterMetadata​(org.apache.kafka.common.Cluster cluster)
      • setPartitionsByHostState

        public void setPartitionsByHostState​(java.util.Map<HostInfo,​java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHostState)
      • setAssignmentMetadata

        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)
      • updateSubscriptionsFromAssignment

        public void updateSubscriptionsFromAssignment​(java.util.List<org.apache.kafka.common.TopicPartition> partitions)
      • updateSubscriptionsFromMetadata

        public void updateSubscriptionsFromMetadata​(java.util.Set<java.lang.String> topics)
      • toString

        public java.lang.String toString()
        Produces a string representation containing useful information about the TaskManager. This is useful in debugging scenarios.
        Overrides:
        toString in class java.lang.Object
        Returns:
        A string representation of the TaskManager instance.
      • toString

        public java.lang.String toString​(java.lang.String indent)