Package org.apache.flink.table.planner.plan.rules.physical.stream

Interface Summary

Interface	Description
PushCalcPastChangelogNormalizeRule.Config	Configuration for PushCalcPastChangelogNormalizeRule.
WatermarkAssignerChangelogNormalizeTransposeRule.Config	Rule configuration.

Class Summary

Class	Description
ImmutablePushCalcPastChangelogNormalizeRule	ImmutablePushCalcPastChangelogNormalizeRule contains immutable implementation classes generated from abstract value types defined as nested inside PushCalcPastChangelogNormalizeRule.
ImmutablePushCalcPastChangelogNormalizeRule.Config	Immutable implementation of PushCalcPastChangelogNormalizeRule.Config.
ImmutablePushCalcPastChangelogNormalizeRule.Config.Builder	Builds instances of type Config.
ImmutableWatermarkAssignerChangelogNormalizeTransposeRule	ImmutableWatermarkAssignerChangelogNormalizeTransposeRule contains immutable implementation classes generated from abstract value types defined as nested inside WatermarkAssignerChangelogNormalizeTransposeRule.
ImmutableWatermarkAssignerChangelogNormalizeTransposeRule.Config	Immutable implementation of WatermarkAssignerChangelogNormalizeTransposeRule.Config.
ImmutableWatermarkAssignerChangelogNormalizeTransposeRule.Config.Builder	Builds instances of type Config.
PushCalcPastChangelogNormalizeRule	Pushes primary key filters and used fields project through a ChangelogNormalize operator to reduce its state size.
StreamPhysicalAsyncCalcRule	A physical rule for identifying logical async Calcs and converting it to a physical RelNode.
StreamPhysicalCalcRemoveRule	Rule to remove trivial StreamPhysicalCalc.
StreamPhysicalPythonCorrelateRule	The physical rule is responsible for convert FlinkLogicalCorrelate to StreamPhysicalPythonCorrelate.
StreamPhysicalPythonGroupAggregateRule	Rule to convert a FlinkLogicalAggregate into a StreamPhysicalPythonGroupAggregate.
StreamPhysicalPythonGroupTableAggregateRule	Rule to convert a FlinkLogicalTableAggregate into a StreamPhysicalPythonGroupTableAggregateRule.
StreamPhysicalPythonGroupWindowAggregateRule	The physical rule is responsible for converting FlinkLogicalWindowAggregate to StreamPhysicalPythonGroupWindowAggregate.
StreamPhysicalPythonOverAggregateRule	The physical rule is responsible for converting FlinkLogicalOverAggregate to StreamPhysicalPythonOverAggregate.
TwoStageOptimizedWindowAggregateRule	Rule that matches StreamPhysicalWindowAggregate on StreamPhysicalExchange with following condition: the applied windowing is not on processing-time, because processing-time should be materialized in a single node.
WatermarkAssignerChangelogNormalizeTransposeRule	Transpose StreamPhysicalWatermarkAssigner past into StreamPhysicalChangelogNormalize.