Package com.linkedin.davinci.kafka.consumer

Class PartitionReplicaIngestionContext

java.lang.Object

com.linkedin.davinci.kafka.consumer.PartitionReplicaIngestionContext

public class PartitionReplicaIngestionContext
extends Object

This class is for wrapping the information about the role of the partition replica on that host to AggKafkaConsumerService to achieve finer granularity of consumer assignment. Those information should be triggered by store version role (future, current and backup), workload type and leader or follower state. Version role and workload type information are properly managed by StoreIngestionTask to be sent to AggKafkaConsumerService. We could add more information regarding this partition replica if needed in the future.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	PartitionReplicaIngestionContext.VersionRole
static enum	PartitionReplicaIngestionContext.WorkloadType

Constructor Summary

Constructors

Constructor	Description
PartitionReplicaIngestionContext(PubSubTopic versionTopic, PubSubTopicPartition pubSubTopicPartition, PartitionReplicaIngestionContext.VersionRole versionRole, PartitionReplicaIngestionContext.WorkloadType workloadType)

Method Summary

Modifier and Type	Method	Description
static PartitionReplicaIngestionContext.VersionRole	determineStoreVersionRole(int versionNumber, int currentVersionNumber)
static PartitionReplicaIngestionContext.WorkloadType	determineWorkloadType(boolean isActiveActiveReplicationEnabled, boolean isWriteComputationEnabled)
PubSubTopicPartition	getPubSubTopicPartition()
PartitionReplicaIngestionContext.VersionRole	getVersionRole()
PubSubTopic	getVersionTopic()
PartitionReplicaIngestionContext.WorkloadType	getWorkloadType()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PartitionReplicaIngestionContext

public PartitionReplicaIngestionContext(PubSubTopic versionTopic,
 PubSubTopicPartition pubSubTopicPartition,
 PartitionReplicaIngestionContext.VersionRole versionRole,
 PartitionReplicaIngestionContext.WorkloadType workloadType)

Method Details

getVersionRole

public PartitionReplicaIngestionContext.VersionRole getVersionRole()

getPubSubTopicPartition

public PubSubTopicPartition getPubSubTopicPartition()

getVersionTopic

public PubSubTopic getVersionTopic()

getWorkloadType

public PartitionReplicaIngestionContext.WorkloadType getWorkloadType()

determineWorkloadType

public static PartitionReplicaIngestionContext.WorkloadType determineWorkloadType(boolean isActiveActiveReplicationEnabled,
 boolean isWriteComputationEnabled)

determineStoreVersionRole

public static PartitionReplicaIngestionContext.VersionRole determineStoreVersionRole(int versionNumber,
 int currentVersionNumber)