public class AssignmentInfo
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static int |
LATEST_SUPPORTED_VERSION |
Constructor and Description |
---|
AssignmentInfo() |
AssignmentInfo(int version,
java.util.List<TaskId> activeTasks,
java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks,
java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> hostState,
int errCode) |
AssignmentInfo(java.util.List<TaskId> activeTasks,
java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks,
java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> hostState) |
Modifier and Type | Method and Description |
---|---|
java.util.List<TaskId> |
activeTasks() |
static AssignmentInfo |
decode(java.nio.ByteBuffer data) |
java.nio.ByteBuffer |
encode() |
boolean |
equals(java.lang.Object o) |
int |
errCode() |
int |
hashCode() |
int |
latestSupportedVersion() |
java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> |
partitionsByHost() |
java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> |
standbyTasks() |
java.lang.String |
toString() |
int |
version() |
public static final int LATEST_SUPPORTED_VERSION
public AssignmentInfo(java.util.List<TaskId> activeTasks, java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks, java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> hostState)
public AssignmentInfo()
public int version()
public int errCode()
public int latestSupportedVersion()
public java.util.List<TaskId> activeTasks()
public java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks()
public java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHost()
public java.nio.ByteBuffer encode()
TaskAssignmentException
- if method fails to encode the data, e.g., if there is an
IO exception during encodingpublic static AssignmentInfo decode(java.nio.ByteBuffer data)
TaskAssignmentException
- if method fails to decode the data or if the data version is unknownpublic int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object