Class CassandraDynamicTable

java.lang.Object
org.apache.drill.exec.planner.logical.DrillTable
org.apache.drill.exec.store.cassandra.schema.CassandraDynamicTable
All Implemented Interfaces:
org.apache.calcite.schema.QueryableTable, org.apache.calcite.schema.Table, org.apache.calcite.schema.TranslatableTable, org.apache.calcite.schema.Wrapper

public class CassandraDynamicTable extends DrillTable implements org.apache.calcite.schema.TranslatableTable, org.apache.calcite.schema.QueryableTable, org.apache.calcite.schema.Wrapper
  • Constructor Details

    • CassandraDynamicTable

      public CassandraDynamicTable(StoragePlugin plugin, String storageEngineName, DrillTableSelection selection, org.apache.calcite.adapter.cassandra.CassandraTable table)
  • Method Details

    • toRel

      public org.apache.calcite.rel.RelNode toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context, org.apache.calcite.plan.RelOptTable relOptTable)
      Specified by:
      toRel in interface org.apache.calcite.schema.TranslatableTable
      Overrides:
      toRel in class DrillTable
    • asQueryable

      public <V> org.apache.calcite.linq4j.Queryable<V> asQueryable(org.apache.calcite.linq4j.QueryProvider queryProvider, org.apache.calcite.schema.SchemaPlus schema, String tableName)
      Specified by:
      asQueryable in interface org.apache.calcite.schema.QueryableTable
    • getElementType

      public Type getElementType()
      Specified by:
      getElementType in interface org.apache.calcite.schema.QueryableTable
    • unwrap

      public <C> C unwrap(Class<C> aClass)
      Specified by:
      unwrap in interface org.apache.calcite.schema.Wrapper
    • getExpression

      public org.apache.calcite.linq4j.tree.Expression getExpression(org.apache.calcite.schema.SchemaPlus schema, String tableName, Class clazz)
      Specified by:
      getExpression in interface org.apache.calcite.schema.QueryableTable
    • getRowType

      public org.apache.calcite.rel.type.RelDataType getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
      Specified by:
      getRowType in interface org.apache.calcite.schema.Table