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,
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 | Field and Description |
---|---|
protected TableConfig |
TableEnvironmentImpl.tableConfig |
Modifier and Type | Method and Description |
---|---|
TableConfig |
TableEnvironmentImpl.getConfig() |
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 |
---|---|
TableConfig |
PlannerFactory.Context.getTableConfig()
The configuration of the planner to use.
|
TableConfig |
PlannerFactory.DefaultPlannerContext.getTableConfig() |
Constructor and Description |
---|
DefaultPlannerContext(Executor executor,
TableConfig tableConfig,
ClassLoader classLoader,
ModuleManager moduleManager,
CatalogManager catalogManager,
FunctionCatalog functionCatalog) |
Modifier and Type | Method and Description |
---|---|
static ExpressionResolver.ExpressionResolverBuilder |
ExpressionResolver.resolverFor(TableConfig tableConfig,
ClassLoader userClassLoader,
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,
ClassLoader userClassLoader,
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,
ClassLoader userClassLoader,
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,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
static List<String> |
HiveSetProcessor.dumpOptions(Properties p,
HiveConf hiveConf,
Map<String,String> hiveVariables,
TableConfig tableConfig) |
Modifier and Type | Method and Description |
---|---|
TableConfig |
SourceAbilityContext.getTableConfig() |
Modifier and Type | Method and Description |
---|---|
static List<org.apache.calcite.rel.RelNode> |
StreamNonDeterministicPhysicalPlanResolver.resolvePhysicalPlan(List<org.apache.calcite.rel.RelNode> expanded,
TableConfig tableConfig)
Try to resolve the NDU problem if configured
OptimizerConfigOptions.TABLE_OPTIMIZER_NONDETERMINISTIC_UPDATE_STRATEGY is in `TRY_RESOLVE`
mode. |
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 LookupJoinUtil.AsyncLookupOptions |
LookupJoinUtil.getMergedAsyncOptions(org.apache.calcite.rel.hint.RelHint lookupHint,
TableConfig config,
ChangelogMode inputChangelogMode) |
Modifier and Type | Method and Description |
---|---|
static TableConfig |
ShortcutUtils.unwrapTableConfig(org.apache.calcite.rel.RelNode relNode) |
static TableConfig |
ShortcutUtils.unwrapTableConfig(org.apache.calcite.plan.RelOptRuleCall relOptRuleCall) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
ResourceManager.addJarConfiguration(TableConfig tableConfig)
Adds the local jar resources to the given
TableConfig . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.