Class | Description |
---|---|
BatchPhysicalPythonAggregateRule |
The physical rule which is responsible for converting
FlinkLogicalAggregate to BatchPhysicalPythonGroupAggregate . |
BatchPhysicalPythonCorrelateRule |
The physical rule is responsible for convert
FlinkLogicalCorrelate to BatchPhysicalPythonCorrelate . |
BatchPhysicalPythonWindowAggregateRule |
The physical rule is responsible for convert
FlinkLogicalWindowAggregate to BatchPhysicalPythonGroupWindowAggregate . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.