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.StoreAwarePartitionWiseKafkaConsumerService
        • 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.ConsumerAction (implements java.lang.Comparable<T>)
  • com.linkedin.davinci.kafka.consumer.ConsumerSubscriptionCleaner
  • com.linkedin.davinci.kafka.consumer.IngestionBatchProcessor
  • com.linkedin.davinci.kafka.consumer.IngestionThrottler (implements java.io.Closeable)
  • com.linkedin.davinci.kafka.consumer.KafkaClusterBasedRecordThrottler
  • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.ConsumerPoolStrategy
    • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.CurrentVersionConsumerPoolStrategy
    • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.DefaultConsumerPoolStrategy
      • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.AAOrWCLeaderConsumerPoolStrategy
  • com.linkedin.davinci.kafka.consumer.KeyLevelLocksManager
  • com.linkedin.davinci.kafka.consumer.LeaderProducedRecordContext (implements com.linkedin.venice.memory.Measurable)
  • com.linkedin.davinci.kafka.consumer.LeaderProducerCallback (implements com.linkedin.venice.writer.ChunkAwareCallback)
    • com.linkedin.davinci.kafka.consumer.ActiveActiveProducerCallback
  • com.linkedin.davinci.kafka.consumer.MergeConflictResultWrapper
  • 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.PartitionReplicaIngestionContext
  • com.linkedin.davinci.kafka.consumer.PubSubMessageProcessedResult
  • com.linkedin.davinci.kafka.consumer.PubSubMessageProcessedResultWrapper<K,V,OFFSET>
  • com.linkedin.davinci.kafka.consumer.RegionNameUtil
  • com.linkedin.davinci.kafka.consumer.ReplicaHeartbeatInfo
  • 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.TopicPartitionForIngestion
  • com.linkedin.davinci.kafka.consumer.TopicPartitionIngestionInfo
  • com.linkedin.davinci.kafka.consumer.TopicSwitchWrapper
  • com.linkedin.davinci.kafka.consumer.WriteComputeResultWrapper

Interface Hierarchy

• 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.ConsumerPoolType
    • com.linkedin.davinci.kafka.consumer.KafkaConsumerService.ConsumerAssignmentStrategy
    • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.ConsumerPoolStrategyType
    • com.linkedin.davinci.kafka.consumer.LeaderFollowerStateType
    • com.linkedin.davinci.kafka.consumer.PartitionReplicaIngestionContext.VersionRole
    • com.linkedin.davinci.kafka.consumer.PartitionReplicaIngestionContext.WorkloadType
    • com.linkedin.davinci.kafka.consumer.StoreIngestionTask.DelegateConsumerRecordResult