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

Interface Summary

Interface	Description
RankProcessStrategy	Base class of Strategy to choose different rank process function.

Class Summary

Class	Description
AsyncUtil	Contains utilities for AsyncScalarFunction.
AsyncUtil.Options	Options for configuring async behavior.
ConstantFoldingUtil	Utility for deciding whether than expression supports constant folding or not.
ExecNodeMetadataUtil	Utility class for ExecNodeMetadata related functionality.
ExecNodeMetadataUtil.ExecNodeNameVersion	Helper Pojo used as a tuple for the ExecNodeMetadataUtil.LOOKUP_MAP.
FlinkRelUtil	Utilities for RelNode.
JoinTypeUtil	Utility for FlinkJoinType.
KeySelectorUtil	Utility for KeySelector.
LookupJoinUtil	Utilities for lookup joins using LookupTableSource.
LookupJoinUtil.AsyncLookupOptions	AsyncLookupOptions includes async related options.
LookupJoinUtil.ConstantLookupKey	A LookupJoinUtil.LookupKey whose value is constant.
LookupJoinUtil.FieldRefLookupKey	A LookupJoinUtil.LookupKey whose value comes from the left table field.
LookupJoinUtil.LookupKey	A field used as an equal condition when querying content from a dimension table.
LookupJoinUtil.RetryLookupOptions	RetryOptions includes retry lookup related options.
MinibatchUtil	Utility class for mini-batch related config.
PythonUtil	Utility for Python.
RankProcessStrategy.AppendFastStrategy	A strategy which only works when input only contains insertion changes.
RankProcessStrategy.RetractStrategy	A strategy which works when input contains update or deletion changes.
RankProcessStrategy.UndefinedStrategy	A placeholder strategy which will be inferred after FlinkChangelogModeInferenceProgram.
RankProcessStrategy.UpdateFastStrategy	A strategy which only works when input shouldn't contains deletion changes and input should have the given RankProcessStrategy.UpdateFastStrategy.primaryKeys and should be monotonic on the order by field.
RelDescriptionWriterImpl	Converts an RelNode to string with only the information from the RelNode itself without the information from its inputs.
RexLiteralUtil	Utilities to work with RexLiteral.
SetOpRewriteUtil	Util class that rewrite SetOp.
SorMergeJoinOperatorUtil	Utility for SortMergeJoinOperator.
TemporalTableJoinUtil	Utility for temporal table join which will gradually replace the scala class TemporalJoinUtil.
UpsertKeyUtil	Utility for upsertKey which represented as a Set of ImmutableBitSet.
WindowTableFunctionUtil	Utilities for Window Table Function.

Enum Summary

Enum	Description
OperatorType	Some dedicated operator type which is used in ExecutionConfigOptions.TABLE_EXEC_DISABLED_OPERATORS.