Package com.linkedin.davinci.storage

Interface IngestionMetadataRetriever

All Known Implementing Classes:

IngestionMetadataRetrieverDelegator

public interface IngestionMetadataRetriever

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)

Method Detail

getStoreVersionCompressionDictionary

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

getConsumptionSnapshots

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

getTopicPartitionIngestionContext

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

getHeartbeatLag

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