Modifier and Type | Method and Description |
---|---|
static void |
PythonConfigUtil.declareManagedMemory(Transformation<?> transformation,
StreamExecutionEnvironment env,
TableConfig tableConfig)
Set Python Operator Use Managed Memory.
|
static Configuration |
PythonConfigUtil.getMergedConfig(ExecutionEnvironment env,
TableConfig tableConfig) |
static Configuration |
PythonConfigUtil.getMergedConfig(StreamExecutionEnvironment env,
TableConfig tableConfig) |
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 | 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,
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) |
Constructor and Description |
---|
CatalogCalciteSchema(boolean isStreamingMode,
String catalogName,
CatalogManager catalogManager,
TableConfig tableConfig) |
CatalogManagerCalciteSchema(CatalogManager catalogManager,
TableConfig tableConfig,
boolean isStreamingMode) |
FunctionCatalog(TableConfig config,
CatalogManager catalogManager,
ModuleManager moduleManager) |
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 . |
Pipeline |
Executor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName)
Translates the given transformations to a Pipeline.
|
Modifier and Type | Method and Description |
---|---|
Pipeline |
StreamExecutor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName) |
Modifier and Type | Method and Description |
---|---|
static ExpressionResolver.ExpressionResolverBuilder |
ExpressionResolver.resolverFor(TableConfig config,
TableReferenceLookup tableCatalog,
FunctionLookup functionLookup,
DataTypeFactory typeFactory,
QueryOperation... inputs)
Creates a builder for
ExpressionResolver . |
Modifier and Type | Method and Description |
---|---|
static OperationTreeBuilder |
OperationTreeBuilder.create(TableConfig config,
FunctionLookup functionCatalog,
DataTypeFactory typeFactory,
TableReferenceLookup tableReferenceLookup,
boolean isStreamingMode) |
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) |
Pipeline |
BatchExecutor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName) |
Pipeline |
StreamExecutor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName) |
Constructor and Description |
---|
PlannerContext(TableConfig tableConfig,
FunctionCatalog functionCatalog,
CatalogManager catalogManager,
org.apache.calcite.jdbc.CalciteSchema rootSchema,
List<org.apache.calcite.plan.RelTraitDef> traitDefs) |
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 boolean |
DynamicSourceUtils.isSourceChangeEventsDuplicate(CatalogTable catalogTable,
DynamicTableSource tableSource,
TableConfig config)
Returns true if the table source produces duplicate change events.
|
static void |
DynamicSourceUtils.prepareDynamicSource(ObjectIdentifier sourceIdentifier,
CatalogTable table,
DynamicTableSource source,
boolean isStreamingMode,
TableConfig config)
Prepares the given
DynamicTableSource . |
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.
|
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–2021 The Apache Software Foundation. All rights reserved.