Package org.apache.flink.table.planner.utils

Class Summary

Class	Description
CatalogTableStatisticsConverter	Utility class for converting CatalogTableStatistics and CatalogColumnStatistics to TableStats.
DummyStreamExecutionEnvironment	This is dummy StreamExecutionEnvironment, which holds a real StreamExecutionEnvironment, shares all configurations of the real environment, and disables all configuration setting methods.
DynamicPartitionPruningUtils	Planner utils for Dynamic partition Pruning.
Expander	Utility that expand SQL identifiers in a SQL query.
Expander.Expanded	Result of expanding.
FlinkTypeUtils	Utils for mapping Calcite's type to Flink's type, most code is copied from FlinkTypeFactory.
HiveCatalogUtils	Utils related to Hive Catalog for Hive dialect.
InternalConfigOptions	This class holds internal configuration constants used by Flink's table module.
OperationConverterUtils	Utils methods for converting sql to operations.
RowLevelModificationContextUtils	Utils for putting/getting RowLevelModificationScanContext/SupportsRowLevelModificationScan.RowLevelModificationType in current thread, it enables to put/get them in different methods.
ShortcutUtils	Utilities for quick access of commonly used instances (like FlinkTypeFactory) without long chains of getters or casting like (FlinkTypeFactory) agg.getCluster.getTypeFactory().
StreamExchangeModeUtils	Utility class to load job-wide exchange mode.
TableConfigUtils	Utility class for TableConfig related helper functions.
TableSchemaUtils	Utils methods for converting table schema.
TimestampStringUtils	Utility functions for calcite's TimestampString.

Enum Summary

Enum	Description
AggregatePhaseStrategy	Aggregate phase strategy which could be specified in OptimizerConfigOptions.TABLE_OPTIMIZER_AGG_PHASE_STRATEGY.