Package com.linkedin.davinci.kafka.consumer

Class TopicPartitionForIngestion

java.lang.Object

com.linkedin.davinci.kafka.consumer.TopicPartitionForIngestion

public class TopicPartitionForIngestion
extends Object

This class is a wrapper of pair of <Version Topic, Version /Real time topic partition>. As for a unique topic partition to be ingested, We need both version topic and pub-sub topic partition to identify. For example, the server host may ingestion same {#linkPubSubTopicType.REALTIME_TOPIC} partition from different {#link PubSubTopicType.VERSION_TOPIC}s, and we should avoid sharing the same consumer for them. TODO： Modify the Consumer Service to use this class instead of using version topic and pub-sub topic partition separately.

Constructor Summary

Constructors

Constructor	Description
TopicPartitionForIngestion(PubSubTopic versionTopic, PubSubTopicPartition pubSubTopicPartition)

Method Summary

Modifier and Type	Method	Description
final boolean	equals(Object obj)
PubSubTopicPartition	getPubSubTopicPartition()
PubSubTopic	getVersionTopic()
final int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Details

TopicPartitionForIngestion

public TopicPartitionForIngestion(PubSubTopic versionTopic,
 PubSubTopicPartition pubSubTopicPartition)

Method Details

getVersionTopic

public PubSubTopic getVersionTopic()

getPubSubTopicPartition

public PubSubTopicPartition getPubSubTopicPartition()

hashCode

public final int hashCode()

Overrides:

hashCode in class Object

equals

public final boolean equals(Object obj)

Overrides:

equals in class Object