Class KafkaStoragePlugin

java.lang.Object
org.apache.drill.exec.store.AbstractStoragePlugin
org.apache.drill.exec.store.kafka.KafkaStoragePlugin
All Implemented Interfaces:
AutoCloseable, SchemaFactory, StoragePlugin

public class KafkaStoragePlugin extends AbstractStoragePlugin
  • Constructor Details

  • Method Details

    • getConfig

      public KafkaStoragePluginConfig getConfig()
      Description copied from interface: StoragePlugin
      Method returns a Jackson serializable object that extends a StoragePluginConfig.
      Returns:
      an extension of StoragePluginConfig
    • supportsRead

      public boolean supportsRead()
      Description copied from interface: StoragePlugin
      Indicates if Drill can read the table from this format.
      Specified by:
      supportsRead in interface StoragePlugin
      Overrides:
      supportsRead in class AbstractStoragePlugin
    • registerSchemas

      public void registerSchemas(SchemaConfig schemaConfig, org.apache.calcite.schema.SchemaPlus parent)
      Description copied from interface: SchemaFactory
      Register the schemas provided by this SchemaFactory implementation under the given parent schema.
      Parameters:
      schemaConfig - Configuration for schema objects.
      parent - Reference to parent schema.
    • getOptimizerRules

      public Set<StoragePluginOptimizerRule> getOptimizerRules(OptimizerRulesContext optimizerRulesContext, PlannerPhase phase)
      Description copied from interface: StoragePlugin
      An implementation of this method will return one or more specialized rules that Drill query optimizer can leverage in physical space. Otherwise, it should return an empty set.
      Returns:
      an empty set or a set of plugin specific physical optimizer rules.
    • getPhysicalScan

      public AbstractGroupScan getPhysicalScan(String userName, JSONOptions selection) throws IOException
      Description copied from interface: StoragePlugin
      Get the physical scan operator for the particular GroupScan (read) node.
      Specified by:
      getPhysicalScan in interface StoragePlugin
      Overrides:
      getPhysicalScan in class AbstractStoragePlugin
      Parameters:
      userName - User whom to impersonate when when reading the contents as part of Scan.
      selection - The configured storage engine specific selection.
      Returns:
      The physical scan operator for the particular GroupScan (read) node.
      Throws:
      IOException
    • registerToClose

      public void registerToClose(AutoCloseable autoCloseable)
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Overrides:
      close in class AbstractStoragePlugin