Package com.linkedin.davinci.storage

Interface IngestionMetadataRetriever

All Known Subinterfaces:

StoreIngestionService

All Known Implementing Classes:

KafkaStoreIngestionService

public interface IngestionMetadataRetriever

Method Summary

Modifier and Type	Method	Description
AdminResponse	getConsumptionSnapshots(java.lang.String topicName, ComplementSet<java.lang.Integer> partitions)
java.nio.ByteBuffer	getStoreVersionCompressionDictionary(java.lang.String topicName)
TopicPartitionIngestionContextResponse	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

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