Package | Description |
---|---|
org.apache.flink.table.planner.plan.rules.physical.batch |
Modifier and Type | Class and Description |
---|---|
class |
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 . |
class |
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 . |
class |
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 . |
class |
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 . |
class |
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 . |
class |
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.