Package com.linkedin.davinci.storage

Class IngestionMetadataRetrieverDelegator

java.lang.Object

com.linkedin.davinci.storage.IngestionMetadataRetrieverDelegator

All Implemented Interfaces:

IngestionMetadataRetriever

public class IngestionMetadataRetrieverDelegator
extends Object
implements IngestionMetadataRetriever

Constructor Summary

Constructors

Constructor	Description
IngestionMetadataRetrieverDelegator(KafkaStoreIngestionService kafkaStoreIngestionService, HeartbeatMonitoringService heartbeatMonitoringService)

Method Summary

Modifier and Type	Method	Description
AdminResponse	getConsumptionSnapshots(String topicName, ComplementSet<Integer> partitions)
ReplicaIngestionResponse	getHeartbeatLag(String versionTopicName, int partitionFilter, boolean filterLagReplica)
ByteBuffer	getStoreVersionCompressionDictionary(String topicName)
ReplicaIngestionResponse	getTopicPartitionIngestionContext(String versionTopic, String topicName, int partitionNum)

Methods inherited from class java.lang.Object

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

Constructor Details

IngestionMetadataRetrieverDelegator

public IngestionMetadataRetrieverDelegator(KafkaStoreIngestionService kafkaStoreIngestionService,
 HeartbeatMonitoringService heartbeatMonitoringService)

Method Details

getStoreVersionCompressionDictionary

public ByteBuffer getStoreVersionCompressionDictionary(String topicName)

Specified by:

getStoreVersionCompressionDictionary in interface IngestionMetadataRetriever

getConsumptionSnapshots

public AdminResponse getConsumptionSnapshots(String topicName,
 ComplementSet<Integer> partitions)

Specified by:

getConsumptionSnapshots in interface IngestionMetadataRetriever

getTopicPartitionIngestionContext

public ReplicaIngestionResponse getTopicPartitionIngestionContext(String versionTopic,
 String topicName,
 int partitionNum)

Specified by:

getTopicPartitionIngestionContext in interface IngestionMetadataRetriever

getHeartbeatLag

public ReplicaIngestionResponse getHeartbeatLag(String versionTopicName,
 int partitionFilter,
 boolean filterLagReplica)

Specified by:

getHeartbeatLag in interface IngestionMetadataRetriever