Interface | Description |
---|---|
WatermarkAssignerChangelogNormalizeTransposeRule.Config |
Rule configuration.
|
Class | Description |
---|---|
StreamExecPythonCorrelateRule |
The physical rule is responsible for convert
FlinkLogicalCorrelate to StreamExecPythonCorrelate . |
StreamExecPythonGroupAggregateRule |
Rule to convert a
FlinkLogicalAggregate into a StreamExecPythonGroupAggregate . |
StreamExecPythonGroupWindowAggregateRule |
The physical rule is responsible for converting
FlinkLogicalWindowAggregate to StreamExecPythonGroupWindowAggregate . |
StreamExecPythonOverAggregateRule |
The physical rule is responsible for converting
FlinkLogicalOverAggregate to StreamExecPythonOverAggregate . |
WatermarkAssignerChangelogNormalizeTransposeRule |
Transpose
StreamExecWatermarkAssigner past into StreamExecChangelogNormalize . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.