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 . |
PushLocalAggIntoScanRuleBase |
Planner rule that tries to push a local aggregator into an
BatchPhysicalTableSourceScan
whose table is a TableSourceTable with a source supporting SupportsAggregatePushDown . |
PushLocalHashAggIntoScanRule |
Planner rule that tries to push a local hash aggregate which without sort into a
BatchPhysicalTableSourceScan whose table is a TableSourceTable with a source supporting
SupportsAggregatePushDown . |
PushLocalHashAggWithCalcIntoScanRule |
Planner rule that tries to push a local hash aggregate which with calc into a
BatchPhysicalTableSourceScan whose table is a TableSourceTable with a source supporting
SupportsAggregatePushDown . |
PushLocalSortAggIntoScanRule |
Planner rule that tries to push a local sort aggregate which without sort into a
BatchPhysicalTableSourceScan whose table is a TableSourceTable with a source supporting
SupportsAggregatePushDown . |
PushLocalSortAggWithCalcIntoScanRule |
Planner rule that tries to push a local sort aggregate which without sort into a
BatchPhysicalTableSourceScan whose table is a TableSourceTable with a source supporting
SupportsAggregatePushDown . |
PushLocalSortAggWithSortAndCalcIntoScanRule |
Planner rule that tries to push a local sort aggregate which with sort and calc into a
BatchPhysicalTableSourceScan whose table is a TableSourceTable with a source supporting
SupportsAggregatePushDown . |
PushLocalSortAggWithSortIntoScanRule |
Planner rule that tries to push a local sort aggregate which with sort into a
BatchPhysicalTableSourceScan whose table is a TableSourceTable with a source supporting
SupportsAggregatePushDown . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.