Package org.apache.kafka.streams.processor.internals.assignment

Class AssignmentInfo

java.lang.Object

org.apache.kafka.streams.processor.internals.assignment.AssignmentInfo

public class AssignmentInfo
extends Object

Constructor Summary

Constructors

Constructor	Description
AssignmentInfo(int version, int commonlySupportedVersion)
AssignmentInfo(int version, int commonlySupportedVersion, List<TaskId> activeTasks, Map<TaskId,Set<TopicPartition>> standbyTasks, Map<HostInfo,Set<TopicPartition>> partitionsByHost, Map<HostInfo,Set<TopicPartition>> standbyPartitionsByHost, int errCode)
AssignmentInfo(int version, List<TaskId> activeTasks, Map<TaskId,Set<TopicPartition>> standbyTasks, Map<HostInfo,Set<TopicPartition>> partitionsByHost, Map<HostInfo,Set<TopicPartition>> standbyPartitionsByHost, int errCode)

Method Summary

Modifier and Type	Method	Description
List<TaskId>	activeTasks()
int	commonlySupportedVersion()
static AssignmentInfo	decode(ByteBuffer data)
ByteBuffer	encode()
boolean	equals(Object o)
int	errCode()
int	hashCode()
long	nextRebalanceMs()
Map<HostInfo,Set<TopicPartition>>	partitionsByHost()
void	setNextRebalanceTime(long nextRebalanceTimeMs)
Map<HostInfo,Set<TopicPartition>>	standbyPartitionByHost()
Map<TaskId,Set<TopicPartition>>	standbyTasks()
String	toString()
int	version()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AssignmentInfo

public AssignmentInfo(int version,
                      int commonlySupportedVersion)

AssignmentInfo

public AssignmentInfo(int version,
                      List<TaskId> activeTasks,
                      Map<TaskId,Set<TopicPartition>> standbyTasks,
                      Map<HostInfo,Set<TopicPartition>> partitionsByHost,
                      Map<HostInfo,Set<TopicPartition>> standbyPartitionsByHost,
                      int errCode)

AssignmentInfo

public AssignmentInfo(int version,
                      int commonlySupportedVersion,
                      List<TaskId> activeTasks,
                      Map<TaskId,Set<TopicPartition>> standbyTasks,
                      Map<HostInfo,Set<TopicPartition>> partitionsByHost,
                      Map<HostInfo,Set<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 List<TaskId> activeTasks()

standbyTasks

public Map<TaskId,Set<TopicPartition>> standbyTasks()

partitionsByHost

public Map<HostInfo,Set<TopicPartition>> partitionsByHost()

standbyPartitionByHost

public Map<HostInfo,Set<TopicPartition>> standbyPartitionByHost()

nextRebalanceMs

public long nextRebalanceMs()

encode

public 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(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 class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object