Package com.linkedin.davinci.storage

Class IngestionMetadataRetrieverDelegator

java.lang.Object

com.linkedin.davinci.storage.IngestionMetadataRetrieverDelegator

All Implemented Interfaces:

IngestionMetadataRetriever

public class IngestionMetadataRetrieverDelegator
extends java.lang.Object
implements IngestionMetadataRetriever

Constructor Summary

Constructors

Constructor	Description
IngestionMetadataRetrieverDelegator(KafkaStoreIngestionService kafkaStoreIngestionService, HeartbeatMonitoringService heartbeatMonitoringService)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

IngestionMetadataRetrieverDelegator

public IngestionMetadataRetrieverDelegator(KafkaStoreIngestionService kafkaStoreIngestionService,
                                           HeartbeatMonitoringService heartbeatMonitoringService)

Method Detail

getStoreVersionCompressionDictionary

public java.nio.ByteBuffer getStoreVersionCompressionDictionary(java.lang.String topicName)

Specified by:

getStoreVersionCompressionDictionary in interface IngestionMetadataRetriever

getConsumptionSnapshots

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

Specified by:

getConsumptionSnapshots in interface IngestionMetadataRetriever

getTopicPartitionIngestionContext

public ReplicaIngestionResponse getTopicPartitionIngestionContext(java.lang.String versionTopic,
                                                                  java.lang.String topicName,
                                                                  int partitionNum)

Specified by:

getTopicPartitionIngestionContext in interface IngestionMetadataRetriever

getHeartbeatLag

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

Specified by:

getHeartbeatLag in interface IngestionMetadataRetriever