public final class TopicPartitionMovement extends AbstractTopicPartitionHistory
Constructor and Description |
---|
TopicPartitionMovement(org.apache.kafka.common.TopicPartition tp,
int sourceBroker,
int destinationBroker,
Class<? extends Goal> proposingGoal,
String movementReason,
long expirationMs,
long epoch)
Creates a new
TopicPartitionMovement and assign the current wall-clock time as its timestamp. |
Modifier and Type | Method and Description |
---|---|
int |
destinationBroker() |
String |
movementReason() |
Class<? extends Goal> |
proposingGoal() |
int |
sourceBroker() |
long |
timestampMs() |
String |
toString() |
deadlineMs, epoch, topicPartition, untilDeadline
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
compareTo
public TopicPartitionMovement(org.apache.kafka.common.TopicPartition tp, int sourceBroker, int destinationBroker, Class<? extends Goal> proposingGoal, String movementReason, long expirationMs, long epoch)
TopicPartitionMovement
and assign the current wall-clock time as its timestamp.tp
- moved topic partitionsourceBroker
- original brokerdestinationBroker
- destination brokerproposingGoal
- the goal that proposed this movementmovementReason
- a string indicating the reason of this movementexpirationMs
- after which this movement will be expired and eligible for evictionepoch
- a monotonically increasing number for detection of obsolete history itempublic int sourceBroker()
public int destinationBroker()
public String movementReason()
public long timestampMs()