Package com.linkedin.davinci.kafka.consumer

Class TopicPartitionForIngestion

java.lang.Object

com.linkedin.davinci.kafka.consumer.TopicPartitionForIngestion

public class TopicPartitionForIngestion
extends java.lang.Object

This class is a wrapper of pair of . 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
boolean	equals(java.lang.Object obj)
PubSubTopicPartition	getPubSubTopicPartition()
PubSubTopic	getVersionTopic()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicPartitionForIngestion

public TopicPartitionForIngestion(PubSubTopic versionTopic,
                                  PubSubTopicPartition pubSubTopicPartition)

Method Detail

getVersionTopic

public PubSubTopic getVersionTopic()

getPubSubTopicPartition

public PubSubTopicPartition getPubSubTopicPartition()

hashCode

public final int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public final boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object