Interface | Description |
---|---|
PushFilterPastChangelogNormalizeRule.Config |
Configuration for
PushFilterPastChangelogNormalizeRule . |
WatermarkAssignerChangelogNormalizeTransposeRule.Config |
Rule configuration.
|
Class | Description |
---|---|
PushFilterPastChangelogNormalizeRule |
Pushes primary key filters through a
ChangelogNormalize
operator to reduce its state size. |
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 . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.