Constructor and Description |
---|
AbstractStreamTableEnvironmentImpl(CatalogManager catalogManager,
ModuleManager moduleManager,
ResourceManager resourceManager,
TableConfig tableConfig,
Executor executor,
FunctionCatalog functionCatalog,
Planner planner,
boolean isStreamingMode,
StreamExecutionEnvironment executionEnvironment) |
Constructor and Description |
---|
StreamTableEnvironmentImpl(CatalogManager catalogManager,
ModuleManager moduleManager,
ResourceManager resourceManager,
FunctionCatalog functionCatalog,
TableConfig tableConfig,
StreamExecutionEnvironment executionEnvironment,
Planner planner,
Executor executor,
boolean isStreamingMode) |
Modifier and Type | Method and Description |
---|---|
CatalogManager |
TableEnvironmentInternal.getCatalogManager()
Returns a
CatalogManager that deals with all catalog objects. |
CatalogManager |
TableEnvironmentImpl.getCatalogManager() |
Constructor and Description |
---|
TableEnvironmentImpl(CatalogManager catalogManager,
ModuleManager moduleManager,
ResourceManager resourceManager,
TableConfig tableConfig,
Executor executor,
FunctionCatalog functionCatalog,
Planner planner,
boolean isStreamingMode) |
Modifier and Type | Method and Description |
---|---|
CatalogManager |
CatalogManager.Builder.build() |
Constructor and Description |
---|
FunctionCatalog(ReadableConfig config,
ResourceManager resourceManager,
CatalogManager catalogManager,
ModuleManager moduleManager) |
Modifier and Type | Field and Description |
---|---|
CatalogManager |
SessionContext.SessionState.catalogManager |
Constructor and Description |
---|
SessionState(CatalogManager catalogManager,
ModuleManager moduleManager,
ClientResourceManager resourceManager,
FunctionCatalog functionCatalog) |
Modifier and Type | Method and Description |
---|---|
CatalogManager |
PlannerFactory.Context.getCatalogManager()
The catalog manager to look up tables and views.
|
CatalogManager |
PlannerFactory.DefaultPlannerContext.getCatalogManager() |
Constructor and Description |
---|
DefaultPlannerContext(Executor executor,
TableConfig tableConfig,
ClassLoader classLoader,
ModuleManager moduleManager,
CatalogManager catalogManager,
FunctionCatalog functionCatalog) |
Modifier and Type | Method and Description |
---|---|
static Planner |
PlannerFactoryUtil.createPlanner(Executor executor,
TableConfig tableConfig,
ClassLoader userClassLoader,
ModuleManager moduleManager,
CatalogManager catalogManager,
FunctionCatalog functionCatalog)
Discovers a planner factory and creates a planner instance.
|
Modifier and Type | Field and Description |
---|---|
CatalogManager |
SessionContext.SessionState.catalogManager |
Constructor and Description |
---|
SessionState(CatalogManager catalogManager,
ModuleManager moduleManager,
ResourceManager resourceManager,
FunctionCatalog functionCatalog) |
Modifier and Type | Method and Description |
---|---|
SinkModifyOperation |
CreateTableASOperation.toSinkModifyOperation(CatalogManager catalogManager) |
Constructor and Description |
---|
CatalogCalciteSchema(String catalogName,
CatalogManager catalog,
boolean isStreamingMode) |
CatalogManagerCalciteSchema(CatalogManager catalogManager,
boolean isStreamingMode) |
Modifier and Type | Method and Description |
---|---|
CatalogManager |
ParserImpl.getCatalogManager() |
CatalogManager |
DialectFactory.Context.getCatalogManager() |
CatalogManager |
DialectFactory.DefaultParserContext.getCatalogManager() |
Constructor and Description |
---|
DefaultParserContext(CatalogManager catalogManager,
PlannerContext plannerContext,
Executor executor) |
ParserImpl(CatalogManager catalogManager,
java.util.function.Supplier<org.apache.flink.table.planner.calcite.FlinkPlannerImpl> validatorSupplier,
java.util.function.Supplier<CalciteParser> calciteParserSupplier,
RexFactory rexFactory) |
PlannerContext(boolean isBatchMode,
TableConfig tableConfig,
ModuleManager moduleManager,
FunctionCatalog functionCatalog,
CatalogManager catalogManager,
org.apache.calcite.jdbc.CalciteSchema rootSchema,
List<org.apache.calcite.plan.RelTraitDef> traitDefs,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
static void |
HiveSessionState.startSessionState(HiveConf hiveConf,
CatalogManager catalogManager) |
Constructor and Description |
---|
HiveOperationExecutor(CatalogManager catalogManager,
PlannerContext plannerContext) |
HiveParserCalcitePlanner(HiveParserQueryState queryState,
PlannerContext plannerContext,
FlinkCalciteCatalogReader catalogReader,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
CatalogManager catalogManager) |
HiveParserDMLHelper(PlannerContext plannerContext,
SqlFunctionConverter funcConverter,
CatalogManager catalogManager) |
Modifier and Type | Method and Description |
---|---|
static CatalogBaseTable |
HiveParserBaseSemanticAnalyzer.getCatalogBaseTable(CatalogManager catalogManager,
ObjectIdentifier tableIdentifier) |
static ObjectIdentifier |
HiveParserBaseSemanticAnalyzer.getObjectIdentifier(CatalogManager catalogManager,
HiveParserASTNode tabNameNode) |
static ObjectIdentifier |
HiveParserBaseSemanticAnalyzer.parseCompoundName(CatalogManager catalogManager,
String compoundName) |
Constructor and Description |
---|
HiveParserSemanticAnalyzer(HiveParserQueryState queryState,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster,
CatalogManager catalogManager) |
TableSpec(CatalogManager catalogManager,
HiveConf conf,
HiveParserASTNode ast,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster) |
Constructor and Description |
---|
HiveParserDDLSemanticAnalyzer(HiveParserQueryState queryState,
HiveCatalog hiveCatalog,
CatalogManager catalogManager,
HiveParser hiveParser,
HiveShim hiveShim,
HiveParserContext context,
HiveParserDMLHelper dmlHelper,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster,
org.apache.flink.table.planner.calcite.FlinkContext flinkContext) |
HiveParserLoadSemanticAnalyzer(HiveConf conf,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster,
CatalogManager catalogManager) |
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() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.