public class TableConfigUtils extends Object
TableConfig
related helper functions.Modifier and Type | Method and Description |
---|---|
static AggregatePhaseStrategy |
getAggPhaseStrategy(TableConfig tableConfig)
Returns the aggregate phase strategy configuration.
|
static org.apache.flink.table.planner.calcite.CalciteConfig |
getCalciteConfig(TableConfig tableConfig)
Returns
CalciteConfig wraps in the given TableConfig. |
static Long |
getMillisecondFromConfigDuration(TableConfig tableConfig,
ConfigOption<String> config)
Returns time in milli second.
|
static boolean |
isOperatorDisabled(TableConfig tableConfig,
OperatorType operatorType)
Returns whether the given operator type is disabled.
|
public static boolean isOperatorDisabled(TableConfig tableConfig, OperatorType operatorType)
tableConfig
- TableConfig objectoperatorType
- operator type to checkpublic static AggregatePhaseStrategy getAggPhaseStrategy(TableConfig tableConfig)
tableConfig
- TableConfig objectpublic static Long getMillisecondFromConfigDuration(TableConfig tableConfig, ConfigOption<String> config)
tableConfig
- TableConfig objectconfig
- config to fetchpublic static org.apache.flink.table.planner.calcite.CalciteConfig getCalciteConfig(TableConfig tableConfig)
CalciteConfig
wraps in the given TableConfig.tableConfig
- TableConfig objectCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.