Hierarchy For Package org.apache.drill.exec.store.kafka

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.drill.exec.physical.base.AbstractBase (implements org.apache.drill.exec.physical.base.PhysicalOperator)
    • org.apache.drill.exec.physical.base.AbstractGroupScan (implements org.apache.drill.exec.physical.base.GroupScan)
      • org.apache.drill.exec.store.kafka.KafkaGroupScan
    • org.apache.drill.exec.store.kafka.KafkaSubScan (implements org.apache.drill.exec.physical.base.SubScan)
  • org.apache.drill.common.expression.visitors.AbstractExprVisitor<T,VAL,EXCEP> (implements org.apache.drill.common.expression.visitors.ExprVisitor<T,VAL,EXCEP>)
    • org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder (implements java.lang.AutoCloseable)
  • org.apache.drill.exec.store.AbstractStoragePlugin (implements org.apache.drill.exec.store.StoragePlugin)
    • org.apache.drill.exec.store.kafka.KafkaStoragePlugin
  • org.apache.drill.exec.store.kafka.KafkaAsyncCloser (implements java.lang.AutoCloseable)
  • org.apache.drill.exec.store.kafka.KafkaGroupScan.PartitionScanWork (implements org.apache.drill.exec.store.schedule.CompleteWork)
  • org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec
  • org.apache.drill.exec.store.kafka.KafkaRecordReader (implements org.apache.drill.exec.physical.impl.scan.framework.ManagedReader<T>)
  • org.apache.drill.exec.store.kafka.KafkaScanBatchCreator (implements org.apache.drill.exec.physical.impl.BatchCreator<T>)
  • org.apache.drill.exec.store.kafka.KafkaScanSpec (implements org.apache.drill.exec.planner.logical.DrillTableSelection)
  • org.apache.drill.exec.store.kafka.MessageIterator (implements java.lang.AutoCloseable, java.util.Iterator<E>)
  • org.apache.drill.exec.store.kafka.ReadOptions
  • org.apache.calcite.plan.RelOptRule
    • org.apache.drill.exec.store.StoragePluginOptimizerRule
      • org.apache.drill.exec.store.kafka.KafkaPushDownFilterIntoScan
  • org.apache.drill.common.logical.StoragePluginConfig
    • org.apache.drill.exec.store.kafka.KafkaStoragePluginConfig

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.drill.exec.store.kafka.MetaDataField