org.apache.drill.exec.store.cassandra.schema

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 Summary

Constructors

Constructor and Description
CassandraDynamicTable(StoragePlugin plugin, String storageEngineName, DrillTableSelection selection, org.apache.calcite.adapter.cassandra.CassandraTable table)

Method Summary

Modifier and Type	Method and Description
<V> org.apache.calcite.linq4j.Queryable<V>	asQueryable(org.apache.calcite.linq4j.QueryProvider queryProvider, org.apache.calcite.schema.SchemaPlus schema, String tableName)
Type	getElementType()
org.apache.calcite.linq4j.tree.Expression	getExpression(org.apache.calcite.schema.SchemaPlus schema, String tableName, Class clazz)
org.apache.calcite.rel.type.RelDataType	getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
org.apache.calcite.rel.RelNode	toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context, org.apache.calcite.plan.RelOptTable relOptTable)
<C> C	unwrap(Class<C> aClass)

Methods inherited from class org.apache.drill.exec.planner.logical.DrillTable

equals, getGroupScan, getJdbcTableType, getMetadataProviderManager, getPlugin, getSelection, getStatistic, getStorageEngineConfig, getStorageEngineName, getUserName, hashCode, isRolledUp, rolledUpColumnValidInsideAgg, setGroupScan, setOptions, setTableMetadataProviderManager

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.calcite.schema.Table

getJdbcTableType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg

Constructor Detail

CassandraDynamicTable

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

Method Detail

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