Modifier and Type | Method and Description |
---|---|
TableConfig |
TableEnvironment.getConfig()
Returns the table config that defines the runtime behavior of the Table API.
|
static TableConfig |
TableConfig.getDefault() |
Modifier and Type | Field and Description |
---|---|
protected TableConfig |
TableEnvironmentImpl.tableConfig |
Modifier and Type | Method and Description |
---|---|
TableConfig |
TableEnvironmentImpl.getConfig() |
Constructor and Description |
---|
TableEnvironmentImpl(CatalogManager catalogManager,
TableConfig tableConfig,
Executor executor,
FunctionCatalog functionCatalog,
Planner planner,
boolean isStreamingMode) |
Modifier and Type | Method and Description |
---|---|
static BatchTableEnvironment |
BatchTableEnvironment.create(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
static StreamTableEnvironment |
StreamTableEnvironment.create(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
Deprecated.
Use
StreamTableEnvironment.create(StreamExecutionEnvironment) and TableEnvironment.getConfig()
for manipulating TableConfig . |
Modifier and Type | Method and Description |
---|---|
static StreamTableEnvironment |
StreamTableEnvironmentImpl.create(StreamExecutionEnvironment executionEnvironment,
EnvironmentSettings settings,
TableConfig tableConfig) |
Constructor and Description |
---|
StreamTableEnvironmentImpl(CatalogManager catalogManager,
FunctionCatalog functionCatalog,
TableConfig tableConfig,
StreamExecutionEnvironment executionEnvironment,
Planner planner,
Executor executor,
boolean isStreamingMode) |
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 |
---|
PlanningConfigurationBuilder(TableConfig tableConfig,
FunctionCatalog functionCatalog,
org.apache.calcite.jdbc.CalciteSchema rootSchema,
org.apache.flink.table.expressions.ExpressionBridge<org.apache.flink.table.expressions.PlannerExpression> expressionBridge) |
Modifier and Type | Field and Description |
---|---|
protected TableConfig |
ExecutorBase.tableConfig |
Modifier and Type | Method and Description |
---|---|
Planner |
BlinkPlannerFactory.create(Map<String,String> properties,
Executor executor,
TableConfig tableConfig,
FunctionCatalog functionCatalog,
CatalogManager catalogManager) |
void |
ExecutorBase.setTableConfig(TableConfig tableConfig) |
Constructor and Description |
---|
PlannerContext(TableConfig tableConfig,
FunctionCatalog functionCatalog,
org.apache.calcite.jdbc.CalciteSchema rootSchema,
List<org.apache.calcite.plan.RelTraitDef> traitDefs) |
Modifier and Type | Method and Description |
---|---|
static AggregatePhaseStrategy |
TableConfigUtils.getAggPhaseStrategy(TableConfig tableConfig)
Returns the aggregate phase strategy configuration.
|
static org.apache.flink.table.planner.calcite.CalciteConfig |
TableConfigUtils.getCalciteConfig(TableConfig tableConfig)
Returns
CalciteConfig wraps in the given TableConfig. |
static Long |
TableConfigUtils.getMillisecondFromConfigDuration(TableConfig tableConfig,
ConfigOption<String> config)
Returns time in milli second.
|
static boolean |
TableConfigUtils.isOperatorDisabled(TableConfig tableConfig,
OperatorType operatorType)
Returns whether the given operator type is disabled.
|
static void |
ExecutorUtils.setBatchProperties(StreamExecutionEnvironment execEnv,
TableConfig tableConfig)
Sets batch properties for
StreamExecutionEnvironment . |
static void |
ExecutorUtils.setBatchProperties(StreamGraph streamGraph,
TableConfig tableConfig)
Sets batch properties for
StreamGraph . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.