org.apache.drill.exec.store.elasticsearch.schema

Class ElasticsearchDynamicTable

java.lang.Object

org.apache.drill.exec.planner.logical.DrillTable

org.apache.drill.exec.planner.logical.DynamicDrillTable

org.apache.drill.exec.store.elasticsearch.schema.ElasticsearchDynamicTable

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 ElasticsearchDynamicTable
extends DynamicDrillTable
implements org.apache.calcite.schema.TranslatableTable, org.apache.calcite.schema.QueryableTable, org.apache.calcite.schema.Wrapper

Constructor Summary

Constructors

Constructor and Description
ElasticsearchDynamicTable(StoragePlugin plugin, String storageEngineName, DrillTableSelection selection, org.apache.calcite.schema.Table table)

Method Summary

Modifier and Type	Method and Description
<T> org.apache.calcite.linq4j.Queryable<T>	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.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.DynamicDrillTable

getRowType

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, getRowType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg

Constructor Detail

ElasticsearchDynamicTable

public ElasticsearchDynamicTable(StoragePlugin plugin,
                                 String storageEngineName,
                                 DrillTableSelection selection,
                                 org.apache.calcite.schema.Table 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 <T> org.apache.calcite.linq4j.Queryable<T> 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