Package com.linkedin.davinci.kafka.consumer

Class ConsumerAction

java.lang.Object

com.linkedin.davinci.kafka.consumer.ConsumerAction

All Implemented Interfaces:

Comparable<ConsumerAction>

public class ConsumerAction
extends Object
implements 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)

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(Object obj)
int	getAttemptsCount()
long	getCreateTimestampInMs()
CompletableFuture<Void>	getFuture()
LeaderFollowerPartitionStateModel.LeaderSessionIdChecker	getLeaderSessionIdChecker()
int	getPartition()
int	getSequenceNumber()
String	getTopic()
PubSubTopicPartition	getTopicPartition()
ConsumerActionType	getType()
int	hashCode()
void	incrementAttempt()
boolean	isHelixTriggeredAction()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

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)

Method Details

getType

public ConsumerActionType getType()

getTopicPartition

public PubSubTopicPartition getTopicPartition()

getTopic

public String getTopic()

getPartition

public int getPartition()

incrementAttempt

public void incrementAttempt()

getAttemptsCount

public int getAttemptsCount()

getSequenceNumber

public int getSequenceNumber()

getLeaderSessionIdChecker

public LeaderFollowerPartitionStateModel.LeaderSessionIdChecker getLeaderSessionIdChecker()

getCreateTimestampInMs

public long getCreateTimestampInMs()

getFuture

public CompletableFuture<Void> getFuture()

isHelixTriggeredAction

public boolean isHelixTriggeredAction()

toString

public String toString()

Overrides:

toString in class Object

compareTo

public int compareTo(ConsumerAction other)

Specified by:

compareTo in interface Comparable<ConsumerAction>

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class 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.