org.apache.druid.sql.calcite.table

Class DatasourceTable

java.lang.Object

org.apache.druid.sql.calcite.table.DruidTable

org.apache.druid.sql.calcite.table.DatasourceTable

All Implemented Interfaces:

org.apache.calcite.schema.Table, org.apache.calcite.schema.TranslatableTable

public class DatasourceTable
extends DruidTable

Represents a SQL table that models a Druid datasource.

Once the catalog code is merged, this class will combine physical information from the segment cache with logical information from the catalog to produce the SQL-user's view of the table. The resulting merged view is used to plan queries and is the source of table information in the INFORMATION_SCHEMA.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DatasourceTable.PhysicalDatasourceMetadata The physical metadata for a datasource, derived from the list of segments published in the Coordinator.

Constructor Summary

Constructors

Constructor and Description
DatasourceTable(DatasourceTable.PhysicalDatasourceMetadata physicalMetadata)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
DataSource	getDataSource()
int	hashCode()
boolean	isBroadcast()
boolean	isJoinable()
org.apache.calcite.rel.RelNode	toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context, org.apache.calcite.plan.RelOptTable table)
String	toString()

Methods inherited from class org.apache.druid.sql.calcite.table.DruidTable

getJdbcTableType, getRowSignature, getRowType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg

Methods inherited from class java.lang.Object

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

Constructor Detail

DatasourceTable

public DatasourceTable(DatasourceTable.PhysicalDatasourceMetadata physicalMetadata)

Method Detail

getDataSource

public DataSource getDataSource()

Specified by:

getDataSource in class DruidTable

isJoinable

public boolean isJoinable()

Specified by:

isJoinable in class DruidTable

isBroadcast

public boolean isBroadcast()

Specified by:

isBroadcast in class DruidTable

toRel

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

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object