Package com.linkedin.davinci.storage
Interface IngestionMetadataRetriever
-
- All Known Subinterfaces:
StoreIngestionService
- All Known Implementing Classes:
KafkaStoreIngestionService
public interface IngestionMetadataRetriever
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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, java.lang.Integer 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, java.lang.Integer partitionNum)
-
-