Class | Description |
---|---|
CatalogTableStatisticsConverter | |
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.
|
MaterializedTableUtils |
The utils for materialized table.
|
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 . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.