Hierarchy For Package com.linkedin.davinci.kafka.consumer

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • com.linkedin.venice.service.AbstractVeniceService (implements java.io.Closeable)
    • com.linkedin.davinci.kafka.consumer.AbstractKafkaConsumerService
      • com.linkedin.davinci.kafka.consumer.KafkaConsumerService
        • com.linkedin.davinci.kafka.consumer.PartitionWiseKafkaConsumerService
        • com.linkedin.davinci.kafka.consumer.TopicWiseKafkaConsumerService
      • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator
    • com.linkedin.davinci.kafka.consumer.AbstractStoreBufferService
      • com.linkedin.davinci.kafka.consumer.SeparatedStoreBufferService
      • com.linkedin.davinci.kafka.consumer.StoreBufferService
    • com.linkedin.davinci.kafka.consumer.AggKafkaConsumerService
    • com.linkedin.davinci.kafka.consumer.KafkaStoreIngestionService (implements com.linkedin.davinci.kafka.consumer.StoreIngestionService)
    • com.linkedin.davinci.kafka.consumer.RemoteIngestionRepairService
  • com.linkedin.davinci.kafka.consumer.AmplificationFactorAdapter
  • com.linkedin.davinci.kafka.consumer.ConsumerAction (implements java.lang.Comparable<T>)
  • com.linkedin.davinci.kafka.consumer.ConsumerSubscriptionCleaner
  • com.linkedin.davinci.kafka.consumer.KafkaClusterBasedRecordThrottler
  • com.linkedin.davinci.kafka.consumer.KeyLevelLocksManager
  • com.linkedin.davinci.kafka.consumer.LeaderProducedRecordContext
  • com.linkedin.davinci.kafka.consumer.LeaderProducerCallback (implements com.linkedin.venice.writer.ChunkAwareCallback)
    • com.linkedin.davinci.kafka.consumer.ActiveActiveProducerCallback
  • com.linkedin.davinci.kafka.consumer.MemoryBoundBlockingQueue<T> (implements java.util.concurrent.BlockingQueue<E>)
  • com.linkedin.davinci.kafka.consumer.MetadataRepoBasedTopicExistingCheckerImpl (implements com.linkedin.davinci.kafka.consumer.TopicExistenceChecker)
  • com.linkedin.davinci.kafka.consumer.ParticipantStoreConsumptionTask (implements java.io.Closeable, java.lang.Runnable)
  • com.linkedin.davinci.kafka.consumer.PartitionConsumptionState
  • com.linkedin.davinci.kafka.consumer.PartitionConsumptionState.TransientRecord
  • com.linkedin.davinci.kafka.consumer.StatusReportAdapter
  • com.linkedin.davinci.kafka.consumer.StorageUtilizationManager (implements com.linkedin.venice.meta.StoreDataChangedListener)
  • com.linkedin.davinci.kafka.consumer.StoreIngestionTask (implements java.io.Closeable, java.lang.Runnable)
    • com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask
      • com.linkedin.davinci.kafka.consumer.ActiveActiveStoreIngestionTask
  • com.linkedin.davinci.kafka.consumer.StoreIngestionTaskFactory
  • com.linkedin.davinci.kafka.consumer.StoreIngestionTaskFactory.Builder
  • com.linkedin.davinci.kafka.consumer.StorePartitionDataReceiver (implements com.linkedin.davinci.ingestion.consumption.ConsumedDataReceiver<MESSAGE>)
  • com.linkedin.davinci.kafka.consumer.StoreWriteComputeProcessor
  • com.linkedin.davinci.kafka.consumer.TopicPartitionIngestionInfo
  • com.linkedin.davinci.kafka.consumer.TopicSwitchWrapper

Interface Hierarchy

• com.linkedin.davinci.storage.IngestionMetadataRetriever
  • com.linkedin.davinci.kafka.consumer.StoreIngestionService
• com.linkedin.davinci.kafka.consumer.TopicExistenceChecker
• com.linkedin.davinci.kafka.consumer.TopicPartitionConsumerFunction

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • com.linkedin.davinci.kafka.consumer.ConsumerActionType
    • com.linkedin.davinci.kafka.consumer.KafkaConsumerService.ConsumerAssignmentStrategy
    • com.linkedin.davinci.kafka.consumer.LeaderFollowerStateType
    • com.linkedin.davinci.kafka.consumer.StoreIngestionTask.DelegateConsumerRecordResult