org.apache.drill.exec.store.jdbc.clickhouse

Class ClickhouseCatalogSchema

java.lang.Object

org.apache.drill.exec.store.AbstractSchema

org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseCatalogSchema

All Implemented Interfaces:

AutoCloseable, org.apache.calcite.schema.Schema, SchemaPartitionExplorer

public class ClickhouseCatalogSchema
extends AbstractSchema

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.schema.Schema

org.apache.calcite.schema.Schema.TableType

Field Summary

Fields inherited from class org.apache.drill.exec.store.AbstractSchema

name, SCHEMA_SEPARATOR, schemaPath

Constructor Summary

Constructors

Constructor and Description
ClickhouseCatalogSchema(String name, DataSource source, org.apache.calcite.sql.SqlDialect dialect, DrillJdbcConvention convention)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.schema.Schema	getDefaultSchema() The schema can be a top level schema which doesn't have its own tables, but refers to one of the default sub schemas for table look up.
org.apache.calcite.schema.Table	getTable(String name)
Set<String>	getTableNames()
String	getTypeName() Returns string describing schema type which shows where the schema came from.
void	setHolder(org.apache.calcite.schema.SchemaPlus plusOfThis)

Methods inherited from class org.apache.drill.exec.store.AbstractSchema

appendToStatsTable, applyFunctionParameters, areTableNamesCaseSensitive, close, createNewTable, createNewTable, createStatsTable, createView, dropTable, dropView, getExpression, getFullSchemaName, getFunctionNames, getFunctionParameters, getFunctions, getName, getSchemaPath, getStatsTable, getSubPartitions, getSubSchema, getSubSchemaNames, getTableNamesAndTypes, getTablesByNames, getType, getTypeMap, getTypeNames, getUser, isMutable, needToImpersonateReadingData, showInInformationSchema, snapshot, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ClickhouseCatalogSchema

public ClickhouseCatalogSchema(String name,
                               DataSource source,
                               org.apache.calcite.sql.SqlDialect dialect,
                               DrillJdbcConvention convention)

Method Detail

setHolder

public void setHolder(org.apache.calcite.schema.SchemaPlus plusOfThis)

getTypeName

public String getTypeName()

Description copied from class: AbstractSchema

Returns string describing schema type which shows where the schema came from. Good practice here is to return json type name of storage plugin's config.

Specified by:

getTypeName in class AbstractSchema

Returns:

schema type name

getDefaultSchema

public org.apache.calcite.schema.Schema getDefaultSchema()

Description copied from class: AbstractSchema

The schema can be a top level schema which doesn't have its own tables, but refers to one of the default sub schemas for table look up.

Default implementation returns itself.

Ex. "dfs" schema refers to the tables in "default" workspace when querying for tables in "dfs" schema.

Overrides:

getDefaultSchema in class AbstractSchema

Returns:

Return the default schema where tables are created or retrieved from.

getTable

public org.apache.calcite.schema.Table getTable(String name)

Specified by:

getTable in interface org.apache.calcite.schema.Schema

Overrides:

getTable in class AbstractSchema

getTableNames

public Set<String> getTableNames()

Specified by:

getTableNames in interface org.apache.calcite.schema.Schema

Overrides:

getTableNames in class AbstractSchema