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
PubSubTopicPartition	getPubSubTopicPartition()
static PartitionReplicaIngestionContext.VersionRole	getStoreVersionRole(PubSubTopic versionTopic, Store store)
PartitionReplicaIngestionContext.VersionRole	getVersionRole()
PubSubTopic	getVersionTopic()
PartitionReplicaIngestionContext.WorkloadType	getWorkloadType()
static PartitionReplicaIngestionContext.WorkloadType	getWorkloadType(PubSubTopic versionTopic, Store store)

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()

getWorkloadType

public static PartitionReplicaIngestionContext.WorkloadType getWorkloadType(PubSubTopic versionTopic,
 Store store)

getStoreVersionRole

public static PartitionReplicaIngestionContext.VersionRole getStoreVersionRole(PubSubTopic versionTopic,
 Store store)