Package com.linkedin.davinci.storage

Interface IngestionMetadataRetriever

All Known Implementing Classes:

IngestionMetadataRetrieverDelegator

public interface IngestionMetadataRetriever

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)

Method Details

getStoreVersionCompressionDictionary

ByteBuffer getStoreVersionCompressionDictionary(String topicName)

getConsumptionSnapshots

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

getTopicPartitionIngestionContext

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

getHeartbeatLag

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