Constructor and Description |
---|
StreamTableEnvironmentImpl(CatalogManager catalogManager,
ModuleManager moduleManager,
FunctionCatalog functionCatalog,
TableConfig tableConfig,
StreamExecutionEnvironment executionEnvironment,
Planner planner,
Executor executor,
boolean isStreamingMode,
ClassLoader userClassLoader) |
Modifier and Type | Method and Description |
---|---|
CatalogManager |
TableEnvironmentImpl.getCatalogManager() |
CatalogManager |
TableEnvironmentInternal.getCatalogManager()
Returns a
CatalogManager that deals with all catalog objects. |
Constructor and Description |
---|
TableEnvironmentImpl(CatalogManager catalogManager,
ModuleManager moduleManager,
TableConfig tableConfig,
Executor executor,
FunctionCatalog functionCatalog,
Planner planner,
boolean isStreamingMode,
ClassLoader userClassLoader) |
Modifier and Type | Method and Description |
---|---|
CatalogManager |
CatalogManager.Builder.build() |
Constructor and Description |
---|
CatalogCalciteSchema(boolean isStreamingMode,
String catalogName,
CatalogManager catalogManager,
TableConfig tableConfig) |
CatalogManagerCalciteSchema(CatalogManager catalogManager,
TableConfig tableConfig,
boolean isStreamingMode) |
FunctionCatalog(ReadableConfig config,
CatalogManager catalogManager,
ModuleManager moduleManager) |
FunctionCatalog(TableConfig config,
CatalogManager catalogManager,
ModuleManager moduleManager) |
Modifier and Type | Field and Description |
---|---|
CatalogManager |
SessionContext.SessionState.catalogManager |
Constructor and Description |
---|
SessionState(CatalogManager catalogManager,
ModuleManager moduleManager,
FunctionCatalog functionCatalog) |
Modifier and Type | Method and Description |
---|---|
Planner |
PlannerFactory.create(Map<String,String> properties,
Executor executor,
TableConfig tableConfig,
FunctionCatalog functionCatalog,
CatalogManager catalogManager)
Creates a corresponding
Planner . |
Modifier and Type | Method and Description |
---|---|
Planner |
StreamPlannerFactory.create(Map<String,String> properties,
Executor executor,
TableConfig tableConfig,
FunctionCatalog functionCatalog,
CatalogManager catalogManager) |
Constructor and Description |
---|
ParserImpl(CatalogManager catalogManager,
java.util.function.Supplier<org.apache.flink.table.calcite.FlinkPlannerImpl> validatorSupplier,
java.util.function.Supplier<CalciteParser> calciteParserSupplier) |
Constructor and Description |
---|
CatalogCalciteSchema(String catalogName,
CatalogManager catalog,
boolean isStreamingMode) |
CatalogManagerCalciteSchema(CatalogManager catalogManager,
boolean isStreamingMode) |
Modifier and Type | Method and Description |
---|---|
CatalogManager |
ParserImpl.getCatalogManager() |
Modifier and Type | Method and Description |
---|---|
Parser |
ParserFactory.create(CatalogManager catalogManager,
PlannerContext plannerContext) |
Parser |
DefaultParserFactory.create(CatalogManager catalogManager,
PlannerContext plannerContext) |
Planner |
BlinkPlannerFactory.create(Map<String,String> properties,
Executor executor,
TableConfig tableConfig,
FunctionCatalog functionCatalog,
CatalogManager catalogManager) |
Constructor and Description |
---|
ParserImpl(CatalogManager catalogManager,
java.util.function.Supplier<org.apache.flink.table.planner.calcite.FlinkPlannerImpl> validatorSupplier,
java.util.function.Supplier<CalciteParser> calciteParserSupplier,
SqlExprToRexConverterFactory sqlExprToRexConverterFactory) |
PlannerContext(TableConfig tableConfig,
FunctionCatalog functionCatalog,
CatalogManager catalogManager,
org.apache.calcite.jdbc.CalciteSchema rootSchema,
List<org.apache.calcite.plan.RelTraitDef> traitDefs) |
Modifier and Type | Method and Description |
---|---|
Parser |
HiveParserFactory.create(CatalogManager catalogManager,
PlannerContext plannerContext) |
Constructor and Description |
---|
HiveParserCalcitePlanner(HiveParserQueryState queryState,
PlannerContext plannerContext,
FlinkCalciteCatalogReader catalogReader,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
CatalogManager catalogManager,
HiveShim hiveShim) |
HiveParserDMLHelper(PlannerContext plannerContext,
SqlFunctionConverter funcConverter,
CatalogManager catalogManager) |
Constructor and Description |
---|
HiveParserDDLSemanticAnalyzer(HiveParserQueryState queryState,
HiveCatalog hiveCatalog,
CatalogManager catalogManager,
HiveParser hiveParser,
HiveShim hiveShim,
HiveParserContext context,
HiveParserDMLHelper dmlHelper) |
Modifier and Type | Method and Description |
---|---|
static Optional<Operation> |
SqlToOperationConverter.convert(org.apache.flink.table.planner.calcite.FlinkPlannerImpl flinkPlanner,
CatalogManager catalogManager,
org.apache.calcite.sql.SqlNode sqlNode)
This is the main entrance for executing all kinds of DDL/DML
SqlNode s, different
SqlNode will have it's implementation in the #convert(type) method whose 'type' argument is
subclass of SqlNode . |
Modifier and Type | Method and Description |
---|---|
CatalogManager |
SourceAbilityContext.getCatalogManager() |
Modifier and Type | Method and Description |
---|---|
static Optional<Operation> |
SqlToOperationConverter.convert(org.apache.flink.table.calcite.FlinkPlannerImpl flinkPlanner,
CatalogManager catalogManager,
org.apache.calcite.sql.SqlNode sqlNode)
This is the main entrance for executing all kinds of DDL/DML
SqlNode s, different
SqlNode will have it's implementation in the #convert(type) method whose 'type' argument is
subclass of SqlNode . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.