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() |
<T> TableConfig |
TableConfig.set(ConfigOption<T> option,
T value)
Sets an application-specific value for the given
ConfigOption . |
TableConfig |
TableConfig.set(String key,
String value)
Sets an application-specific string-based value for the given string-based key.
|
Constructor and Description |
---|
AbstractStreamTableEnvironmentImpl(CatalogManager catalogManager,
ModuleManager moduleManager,
TableConfig tableConfig,
Executor executor,
FunctionCatalog functionCatalog,
Planner planner,
boolean isStreamingMode,
ClassLoader userClassLoader,
StreamExecutionEnvironment executionEnvironment) |
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 TableConfig |
TableEnvironmentImpl.tableConfig |
Modifier and Type | Method and Description |
---|---|
TableConfig |
TableEnvironmentImpl.getConfig() |
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 |
---|---|
TableConfig |
PlannerFactory.Context.getTableConfig()
The configuration of the planner to use.
|
TableConfig |
PlannerFactory.DefaultPlannerContext.getTableConfig() |
Constructor and Description |
---|
DefaultPlannerContext(Executor executor,
TableConfig tableConfig,
ModuleManager moduleManager,
CatalogManager catalogManager,
FunctionCatalog functionCatalog) |
Modifier and Type | Method and Description |
---|---|
static ExpressionResolver.ExpressionResolverBuilder |
ExpressionResolver.resolverFor(TableConfig tableConfig,
TableReferenceLookup tableCatalog,
FunctionLookup functionLookup,
DataTypeFactory typeFactory,
SqlExpressionResolver sqlExpressionResolver,
QueryOperation... inputs)
Creates a builder for
ExpressionResolver . |
Modifier and Type | Method and Description |
---|---|
static Planner |
PlannerFactoryUtil.createPlanner(Executor executor,
TableConfig tableConfig,
ModuleManager moduleManager,
CatalogManager catalogManager,
FunctionCatalog functionCatalog)
Discovers a planner factory and creates a planner instance.
|
Modifier and Type | Method and Description |
---|---|
static OperationTreeBuilder |
OperationTreeBuilder.create(TableConfig tableConfig,
FunctionLookup functionCatalog,
DataTypeFactory typeFactory,
TableReferenceLookup tableReferenceLookup,
SqlExpressionResolver sqlExpressionResolver,
boolean isStreamingMode) |
Modifier and Type | Method and Description |
---|---|
static boolean |
DynamicSourceUtils.isSourceChangeEventsDuplicate(ResolvedSchema resolvedSchema,
DynamicTableSource tableSource,
TableConfig tableConfig)
Returns true if the table source produces duplicate change events.
|
Constructor and Description |
---|
PlannerContext(boolean isBatchMode,
TableConfig tableConfig,
ModuleManager moduleManager,
FunctionCatalog functionCatalog,
CatalogManager catalogManager,
org.apache.calcite.jdbc.CalciteSchema rootSchema,
List<org.apache.calcite.plan.RelTraitDef> traitDefs) |
Modifier and Type | Method and Description |
---|---|
TableConfig |
SourceAbilityContext.getTableConfig() |
Modifier and Type | Method and Description |
---|---|
TableConfig |
ExecNodeConfig.getTableConfig()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Tuple2<Pattern<RowData,RowData>,List<String>> |
StreamExecMatch.translatePattern(MatchSpec matchSpec,
TableConfig tableConfig,
org.apache.calcite.tools.RelBuilder relBuilder,
RowType inputRowType) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.table.planner.plan.nodes.logical.FlinkLogicalTableSourceScan |
PushWatermarkIntoTableSourceScanRuleBase.getNewScan(org.apache.flink.table.planner.plan.nodes.logical.FlinkLogicalWatermarkAssigner watermarkAssigner,
org.apache.calcite.rex.RexNode watermarkExpr,
org.apache.flink.table.planner.plan.nodes.logical.FlinkLogicalTableSourceScan scan,
TableConfig tableConfig,
boolean useWatermarkAssignerRowType)
It uses the input watermark expression to generate the
WatermarkGeneratorSupplier . |
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 boolean |
TableConfigUtils.isOperatorDisabled(TableConfig tableConfig,
OperatorType operatorType)
Returns whether the given operator type is disabled.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.