Class CassandraDrillSchema

java.lang.Object
org.apache.drill.exec.store.AbstractSchema
org.apache.drill.exec.store.cassandra.schema.CassandraDrillSchema
All Implemented Interfaces:
AutoCloseable, org.apache.calcite.schema.Schema, SchemaPartitionExplorer

public class CassandraDrillSchema extends AbstractSchema
  • Constructor Details

    • CassandraDrillSchema

      public CassandraDrillSchema(String name, StoragePlugin plugin, org.apache.calcite.adapter.cassandra.CassandraSchema delegatingSchema)
  • Method Details

    • getTypeName

      public String getTypeName()
      Description copied from class: AbstractSchema
      Returns string describing schema type which shows where the schema came from. Good practice here is to return json type name of storage plugin's config.
      Specified by:
      getTypeName in class AbstractSchema
      Returns:
      schema type name
    • getTable

      public org.apache.calcite.schema.Table getTable(String tableName)
      Specified by:
      getTable in interface org.apache.calcite.schema.Schema
      Overrides:
      getTable in class AbstractSchema
    • getTableNames

      public Set<String> getTableNames()
      Specified by:
      getTableNames in interface org.apache.calcite.schema.Schema
      Overrides:
      getTableNames in class AbstractSchema
    • getExpression

      public org.apache.calcite.linq4j.tree.Expression getExpression(org.apache.calcite.schema.SchemaPlus parentSchema, String name)
      Specified by:
      getExpression in interface org.apache.calcite.schema.Schema
      Overrides:
      getExpression in class AbstractSchema
    • getDelegatingSchema

      public org.apache.calcite.adapter.cassandra.CassandraSchema getDelegatingSchema()