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. |
ExecutorUtils |
Utility class to generate StreamGraph and set properties for batch.
|
Expander |
Utility that expand SQL identifiers in a SQL query.
|
Expander.Expanded |
Result of expanding.
|
OperationConverterUtils |
Utils methods for converting sql to operations.
|
ShortcutUtils |
Utilities for quick access of commonly used instances (like
FlinkTypeFactory ) without
long chains of getters or casting like (FlinkTypeFactory)
agg.getCluster.getTypeFactory() . |
ShuffleModeUtils |
Utility class to load job-wide shuffle mode.
|
SingleElementIterator<E> |
Copied from
SingleElementIterator . |
TableConfigUtils |
Utility class for
TableConfig related helper functions. |
Enum | Description |
---|---|
AggregatePhaseStrategy |
Aggregate phase strategy which could be specified in
OptimizerConfigOptions.TABLE_OPTIMIZER_AGG_PHASE_STRATEGY . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.