Package com.linkedin.davinci.kafka.consumer

Class ConsumerAction

java.lang.Object

com.linkedin.davinci.kafka.consumer.ConsumerAction

All Implemented Interfaces:

java.lang.Comparable<ConsumerAction>

public class ConsumerAction
extends java.lang.Object
implements java.lang.Comparable<ConsumerAction>

The class is used to asynchronously trigger behavior changes in the StoreIngestionTask. The kinds of changes that can be triggered by a ConsumerAction are defined in the ConsumerActionType enum.

Constructor Summary

Constructors

Constructor	Description
ConsumerAction(ConsumerActionType type, PubSubTopicPartition topicPartition, int sequenceNumber, boolean isHelixTriggeredAction)
ConsumerAction(ConsumerActionType type, PubSubTopicPartition topicPartition, int sequenceNumber, LeaderFollowerPartitionStateModel.LeaderSessionIdChecker checker, boolean isHelixTriggeredAction)
ConsumerAction(ConsumerActionType type, PubSubTopicPartition topicPartition, int sequenceNumber, java.util.Optional<LeaderFollowerStateType> leaderState, boolean isHelixTriggeredAction)

Method Summary

Modifier and Type	Method	Description
int	compareTo(ConsumerAction other)
static ConsumerAction	createKillAction(PubSubTopic topic, int sequenceNumber)	Create a kill consumer action.
boolean	equals(java.lang.Object obj)
int	getAttemptsCount()
long	getCreateTimestampInMs()
java.util.concurrent.CompletableFuture<java.lang.Void>	getFuture()
LeaderFollowerPartitionStateModel.LeaderSessionIdChecker	getLeaderSessionIdChecker()
LeaderFollowerStateType	getLeaderState()
int	getPartition()
int	getSequenceNumber()
java.lang.String	getTopic()
PubSubTopicPartition	getTopicPartition()
ConsumerActionType	getType()
int	hashCode()
void	incrementAttempt()
boolean	isHelixTriggeredAction()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerAction

public ConsumerAction(ConsumerActionType type,
                      PubSubTopicPartition topicPartition,
                      int sequenceNumber,
                      boolean isHelixTriggeredAction)

ConsumerAction

public ConsumerAction(ConsumerActionType type,
                      PubSubTopicPartition topicPartition,
                      int sequenceNumber,
                      LeaderFollowerPartitionStateModel.LeaderSessionIdChecker checker,
                      boolean isHelixTriggeredAction)

ConsumerAction

public ConsumerAction(ConsumerActionType type,
                      PubSubTopicPartition topicPartition,
                      int sequenceNumber,
                      java.util.Optional<LeaderFollowerStateType> leaderState,
                      boolean isHelixTriggeredAction)

Method Detail

getType

public ConsumerActionType getType()

getTopicPartition

public PubSubTopicPartition getTopicPartition()

getTopic

public java.lang.String getTopic()

getPartition

public int getPartition()

incrementAttempt

public void incrementAttempt()

getAttemptsCount

public int getAttemptsCount()

getSequenceNumber

public int getSequenceNumber()

getLeaderSessionIdChecker

public LeaderFollowerPartitionStateModel.LeaderSessionIdChecker getLeaderSessionIdChecker()

getLeaderState

public LeaderFollowerStateType getLeaderState()

getCreateTimestampInMs

public long getCreateTimestampInMs()

getFuture

public java.util.concurrent.CompletableFuture<java.lang.Void> getFuture()

isHelixTriggeredAction

public boolean isHelixTriggeredAction()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

compareTo

public int compareTo(ConsumerAction other)

Specified by:

compareTo in interface java.lang.Comparable<ConsumerAction>

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

createKillAction

public static ConsumerAction createKillAction(PubSubTopic topic,
                                              int sequenceNumber)

Create a kill consumer action. As kill action apply on all of partitions in given topic, so use 0 as partition value for no meaning.