org.apache.drill.exec.planner.logical

Class DrillTable

java.lang.Object

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

All Implemented Interfaces:

org.apache.calcite.schema.Table

Direct Known Subclasses:

AbstractHBaseDrillTable, CassandraDynamicTable, DrillHiveTable, DynamicDrillTable, InfoSchemaDrillTable, StaticDrillTable

public abstract class DrillTable
extends Object
implements org.apache.calcite.schema.Table

Constructor Summary

Constructors

Constructor and Description
DrillTable(String storageEngineName, StoragePlugin plugin, DrillTableSelection selection) TODO: Same purpose as other constructor except the impersonation user is the user who is running the Drillbit process.
DrillTable(String storageEngineName, StoragePlugin plugin, org.apache.calcite.schema.Schema.TableType tableType, String userName, DrillTableSelection selection) Creates a DrillTable instance.
DrillTable(String storageEngineName, StoragePlugin plugin, org.apache.calcite.schema.Schema.TableType tableType, String userName, DrillTableSelection selection, MetadataProviderManager metadataProviderManager)
DrillTable(String storageEngineName, StoragePlugin plugin, String userName, DrillTableSelection selection) Creates a DrillTable instance for a @{code TableType#Table} table.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
GroupScan	getGroupScan()
org.apache.calcite.schema.Schema.TableType	getJdbcTableType()
MetadataProviderManager	getMetadataProviderManager() Returns manager for TableMetadataProvider which may provide null for the case when scan wasn't created.
StoragePlugin	getPlugin()
Object	getSelection()
org.apache.calcite.schema.Statistic	getStatistic()
StoragePluginConfig	getStorageEngineConfig()
String	getStorageEngineName()
String	getUserName()
int	hashCode()
boolean	isRolledUp(String column)
boolean	rolledUpColumnValidInsideAgg(String column, org.apache.calcite.sql.SqlCall call, org.apache.calcite.sql.SqlNode parent, org.apache.calcite.config.CalciteConnectionConfig config)
void	setGroupScan(GroupScan scan)
void	setOptions(SessionOptionManager options)
void	setTableMetadataProviderManager(MetadataProviderManager metadataProviderManager)
org.apache.calcite.rel.RelNode	toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context, org.apache.calcite.plan.RelOptTable table)

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

getRowType

Constructor Detail

DrillTable

public DrillTable(String storageEngineName,
                  StoragePlugin plugin,
                  String userName,
                  DrillTableSelection selection)

Creates a DrillTable instance for a @{code TableType#Table} table.

Parameters:

storageEngineName - StorageEngine name.

plugin - Reference to StoragePlugin.

userName - Whom to impersonate while reading the contents of the table.

selection - Table contents (type and contents depend on type of StoragePlugin).

DrillTable

public DrillTable(String storageEngineName,
                  StoragePlugin plugin,
                  org.apache.calcite.schema.Schema.TableType tableType,
                  String userName,
                  DrillTableSelection selection)

Creates a DrillTable instance.

Parameters:

storageEngineName - StorageEngine name.

plugin - Reference to StoragePlugin.

tableType - the JDBC table type

userName - Whom to impersonate while reading the contents of the table.

selection - Table contents (type and contents depend on type of StoragePlugin).

DrillTable

public DrillTable(String storageEngineName,
                  StoragePlugin plugin,
                  org.apache.calcite.schema.Schema.TableType tableType,
                  String userName,
                  DrillTableSelection selection,
                  MetadataProviderManager metadataProviderManager)

DrillTable

public DrillTable(String storageEngineName,
                  StoragePlugin plugin,
                  DrillTableSelection selection)

TODO: Same purpose as other constructor except the impersonation user is the user who is running the Drillbit process. Once we add impersonation to non-FileSystem storage plugins such as Hive, HBase etc, we can remove this constructor.

Method Detail

setOptions

public void setOptions(SessionOptionManager options)

setGroupScan

public void setGroupScan(GroupScan scan)

setTableMetadataProviderManager

public void setTableMetadataProviderManager(MetadataProviderManager metadataProviderManager)

getGroupScan

public GroupScan getGroupScan()
                       throws IOException

Throws:

IOException

getMetadataProviderManager

public MetadataProviderManager getMetadataProviderManager()

Returns manager for TableMetadataProvider which may provide null for the case when scan wasn't created. This method should be used only for the case when it is possible to obtain TableMetadataProvider when supplier returns null or TableMetadataProvider usage may be omitted.

Returns:

supplier for TableMetadataProvider

getStorageEngineConfig

public StoragePluginConfig getStorageEngineConfig()

getPlugin

public StoragePlugin getPlugin()

getSelection

public Object getSelection()

getStorageEngineName

public String getStorageEngineName()

getUserName

public String getUserName()

getStatistic

public org.apache.calcite.schema.Statistic getStatistic()

Specified by:

getStatistic in interface org.apache.calcite.schema.Table

toRel

public org.apache.calcite.rel.RelNode toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context,
                                            org.apache.calcite.plan.RelOptTable table)

getJdbcTableType

public org.apache.calcite.schema.Schema.TableType getJdbcTableType()

Specified by:

getJdbcTableType in interface org.apache.calcite.schema.Table

rolledUpColumnValidInsideAgg

public boolean rolledUpColumnValidInsideAgg(String column,
                                            org.apache.calcite.sql.SqlCall call,
                                            org.apache.calcite.sql.SqlNode parent,
                                            org.apache.calcite.config.CalciteConnectionConfig config)

Specified by:

rolledUpColumnValidInsideAgg in interface org.apache.calcite.schema.Table

isRolledUp

public boolean isRolledUp(String column)

Specified by:

isRolledUp in interface org.apache.calcite.schema.Table

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object