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 | Field and Description |
---|---|
protected Planner |
TableEnvironmentImpl.planner |
Modifier and Type | Method and Description |
---|---|
Planner |
TableEnvironmentImpl.getPlanner() |
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 |
---|---|
Planner |
PlannerFactory.create(PlannerFactory.Context context)
Creates a corresponding
Planner . |
Modifier and Type | Method and Description |
---|---|
static Planner |
PlannerFactoryUtil.createPlanner(String plannerIdentifier,
Executor executor,
TableConfig tableConfig,
CatalogManager catalogManager,
FunctionCatalog functionCatalog)
Discovers a planner factory and creates a planner instance.
|
Modifier and Type | Method and Description |
---|---|
Planner |
DefaultPlannerFactory.create(PlannerFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
Transformation<T> |
ExecNodeBase.translateToPlan(Planner planner) |
Transformation<T> |
ExecNodeTranslator.translateToPlan(Planner planner)
Translates this node into a
Transformation . |
Transformation<?> |
ExecEdge.translateToPlan(Planner planner)
Translates this edge into a Flink operator.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.