| Modifier and Type | Method and Description |
|---|---|
static AbstractSchema |
SchemaUtilites.getTemporaryWorkspace(org.apache.calcite.schema.SchemaPlus defaultSchema,
DrillConfig config)
Looks in schema tree for default temporary workspace instance.
|
static AbstractSchema |
SchemaUtilites.resolveToDrillSchema(org.apache.calcite.schema.SchemaPlus defaultSchema,
List<String> schemaPath)
Given reference to default schema in schema tree, search for schema with given schemaPath.
|
static AbstractSchema |
SchemaUtilites.resolveToMutableDrillSchema(org.apache.calcite.schema.SchemaPlus defaultSchema,
List<String> schemaPath)
Given reference to default schema in schema tree, search for schema with given schemaPath.
|
static AbstractSchema |
SchemaUtilites.resolveToTemporarySchema(List<String> tableSchema,
org.apache.calcite.schema.SchemaPlus defaultSchema,
DrillConfig config)
If table schema is not indicated in sql call, returns temporary workspace.
|
static AbstractSchema |
SchemaUtilites.unwrapAsDrillSchemaInstance(org.apache.calcite.schema.SchemaPlus schemaPlus)
Unwrap given SchemaPlus instance as Drill schema instance (AbstractSchema).
|
| Modifier and Type | Method and Description |
|---|---|
static WorkspaceSchemaFactory.WorkspaceSchema |
SchemaUtilites.resolveToValidTemporaryWorkspace(AbstractSchema schema,
DrillConfig config)
Makes sure that passed workspace exists, is default temporary workspace, mutable and file-based
(instance of
WorkspaceSchemaFactory.WorkspaceSchema). |
| Modifier and Type | Method and Description |
|---|---|
protected DrillRel |
AnalyzeTableHandler.convertToDrel(org.apache.calcite.rel.RelNode relNode,
AbstractSchema schema,
String analyzeTableName,
double samplePercent) |
static void |
SqlHandlerUtil.dropTableFromSchema(AbstractSchema drillSchema,
String tableName)
Drops table from schema.
|
static void |
SqlHandlerUtil.dropViewFromSchema(AbstractSchema drillSchema,
String viewName)
Drops view from schema.
|
static org.apache.calcite.schema.Table |
SqlHandlerUtil.getTableFromSchema(AbstractSchema drillSchema,
String tblName) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
UserSession.isTemporaryTable(AbstractSchema drillSchema,
DrillConfig config,
String tableName)
Checks if passed table is temporary, table name is case-insensitive.
|
String |
UserSession.registerTemporaryTable(AbstractSchema schema,
String tableName,
DrillConfig config)
Creates and adds session temporary location if absent using schema configuration.
|
void |
UserSession.removeTemporaryTable(AbstractSchema schema,
String tableName,
DrillConfig config)
Removes temporary table name from the list of session temporary tables.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SubSchemaWrapper |
| Constructor and Description |
|---|
SubSchemaWrapper(AbstractSchema innerSchema) |
| Modifier and Type | Class and Description |
|---|---|
class |
CassandraDrillSchema |
class |
CassandraRootDrillSchema |
| Modifier and Type | Class and Description |
|---|---|
class |
FileSystemSchemaFactory.FileSystemSchema |
class |
WorkspaceSchemaFactory.WorkspaceSchema |
| Modifier and Type | Method and Description |
|---|---|
AbstractSchema |
FileSystemSchemaFactory.FileSystemSchema.getDefaultSchema() |
AbstractSchema |
FileSystemSchemaFactory.FileSystemSchema.getSubSchema(String name) |
| Modifier and Type | Class and Description |
|---|---|
class |
DruidSchemaFactory.DruidDataSources |
| Modifier and Type | Method and Description |
|---|---|
AbstractSchema |
DruidSchemaFactory.DruidDataSources.getSubSchema(String name) |
| Modifier and Type | Class and Description |
|---|---|
class |
ElasticsearchDrillSchema |
| Modifier and Type | Class and Description |
|---|---|
class |
HiveDatabaseSchema |
| Modifier and Type | Class and Description |
|---|---|
class |
HttpAPIConnectionSchema
In the HTTP storage plugin, users can define specific connections or APIs.
|
protected static class |
HttpSchemaFactory.HttpSchema |
| Modifier and Type | Method and Description |
|---|---|
AbstractSchema |
HttpSchemaFactory.HttpSchema.getSubSchema(String name) |
| Modifier and Type | Class and Description |
|---|---|
class |
KafkaMessageSchema |
| Modifier and Type | Class and Description |
|---|---|
class |
MongoDatabaseSchema |
Copyright © 2021 The Apache Software Foundation. All rights reserved.