public class PushFilterInCalcIntoTableSourceScanRule extends PushFilterIntoSourceScanRuleBase
FlinkLogicalCalc and into a FlinkLogicalTableSourceScan.| 限定符和类型 | 字段和说明 |
|---|---|
static PushFilterInCalcIntoTableSourceScanRule |
INSTANCE |
| 构造器和说明 |
|---|
PushFilterInCalcIntoTableSourceScanRule() |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
matches(org.apache.calcite.plan.RelOptRuleCall call) |
void |
onMatch(org.apache.calcite.plan.RelOptRuleCall call) |
canPushdownFilter, convertExpressionToRexNode, createRemainingCondition, extractPredicates, getNewFlinkStatistic, resolveFiltersAndCreateTableSourceTablepublic static final PushFilterInCalcIntoTableSourceScanRule INSTANCE
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.