Class AssignmentInfo
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.assignment.AssignmentInfo
-
public class AssignmentInfo extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description AssignmentInfo(int version, int commonlySupportedVersion)
AssignmentInfo(int version, int commonlySupportedVersion, 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>> partitionsByHost, java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyPartitionsByHost, int errCode)
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>> partitionsByHost, java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyPartitionsByHost, int errCode)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.List<TaskId>
activeTasks()
int
commonlySupportedVersion()
static AssignmentInfo
decode(java.nio.ByteBuffer data)
java.nio.ByteBuffer
encode()
boolean
equals(java.lang.Object o)
int
errCode()
int
hashCode()
long
nextRebalanceMs()
java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>>
partitionsByHost()
void
setNextRebalanceTime(long nextRebalanceTimeMs)
java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>>
standbyPartitionByHost()
java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>>
standbyTasks()
java.lang.String
toString()
int
version()
-
-
-
Constructor Detail
-
AssignmentInfo
public AssignmentInfo(int version, int commonlySupportedVersion)
-
AssignmentInfo
public 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>> partitionsByHost, java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyPartitionsByHost, int errCode)
-
AssignmentInfo
public AssignmentInfo(int version, int commonlySupportedVersion, 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>> partitionsByHost, java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyPartitionsByHost, int errCode)
-
-
Method Detail
-
setNextRebalanceTime
public void setNextRebalanceTime(long nextRebalanceTimeMs)
-
version
public int version()
-
errCode
public int errCode()
-
commonlySupportedVersion
public int commonlySupportedVersion()
-
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()
-
standbyPartitionByHost
public java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyPartitionByHost()
-
nextRebalanceMs
public long nextRebalanceMs()
-
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
-
-