Class AssignmentInfo
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.assignment.AssignmentInfo
-
public class AssignmentInfo extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static int
LATEST_SUPPORTED_VERSION
-
Constructor Summary
Constructors Constructor 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)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
Field Detail
-
LATEST_SUPPORTED_VERSION
public static final int LATEST_SUPPORTED_VERSION
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
AssignmentInfo
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)
-
AssignmentInfo
public AssignmentInfo()
-
-
Method Detail
-
version
public int version()
-
errCode
public int errCode()
-
latestSupportedVersion
public int latestSupportedVersion()
-
activeTasks
public java.util.List<TaskId> activeTasks()
-
standbyTasks
public java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks()
-
partitionsByHost
public java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHost()
-
encode
public java.nio.ByteBuffer encode()
- Throws:
TaskAssignmentException
- if method fails to encode the data, e.g., if there is an IO exception during encoding
-
decode
public static AssignmentInfo decode(java.nio.ByteBuffer data)
- Throws:
TaskAssignmentException
- if method fails to decode the data or if the data version is unknown
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-