org.apache.flink.table.planner.plan.rules.logical

类 PushFilterIntoSourceScanRuleBase

java.lang.Object

org.apache.calcite.plan.RelOptRule

org.apache.flink.table.planner.plan.rules.logical.PushFilterIntoSourceScanRuleBase

直接已知子类:

PushFilterInCalcIntoTableSourceScanRule, PushFilterIntoTableSourceScanRule

public abstract class PushFilterIntoSourceScanRuleBase
extends org.apache.calcite.plan.RelOptRule

Base class for rules that push down filters into table scan.

嵌套类概要

从类继承的嵌套类/接口 org.apache.calcite.plan.RelOptRule

org.apache.calcite.plan.RelOptRule.ConverterRelOptRuleOperand

字段概要

从类继承的字段 org.apache.calcite.plan.RelOptRule

description, operands, relBuilderFactory

构造器概要

构造器

构造器和说明
PushFilterIntoSourceScanRuleBase(org.apache.calcite.plan.RelOptRuleOperand operand, String description)

方法概要

限定符和类型	方法和说明
protected boolean	canPushdownFilter(org.apache.flink.table.planner.plan.schema.TableSourceTable tableSourceTable) Determines wether we can pushdown the filter into the source. we can not push filter twice, make sure FilterPushDownSpec has not been assigned as a capability.
protected List<org.apache.calcite.rex.RexNode>	convertExpressionToRexNode(List<org.apache.flink.table.expressions.ResolvedExpression> expressions, org.apache.calcite.tools.RelBuilder relBuilder)
protected org.apache.calcite.rex.RexNode	createRemainingCondition(org.apache.calcite.tools.RelBuilder relBuilder, List<org.apache.flink.table.expressions.ResolvedExpression> expressions, org.apache.calcite.rex.RexNode[] unconvertedPredicates)
protected scala.Tuple2<org.apache.calcite.rex.RexNode[],org.apache.calcite.rex.RexNode[]>	extractPredicates(String[] inputNames, org.apache.calcite.rex.RexNode filterExpression, org.apache.calcite.rel.core.TableScan scan, org.apache.calcite.rex.RexBuilder rexBuilder)
protected org.apache.flink.table.planner.plan.stats.FlinkStatistic	getNewFlinkStatistic(org.apache.flink.table.planner.plan.schema.TableSourceTable tableSourceTable, int originPredicatesSize, int updatedPredicatesSize)
boolean	matches(org.apache.calcite.plan.RelOptRuleCall call)
protected scala.Tuple2<org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown.Result,org.apache.flink.table.planner.plan.schema.TableSourceTable>	resolveFiltersAndCreateTableSourceTable(org.apache.calcite.rex.RexNode[] convertiblePredicates, org.apache.flink.table.planner.plan.schema.TableSourceTable oldTableSourceTable, org.apache.calcite.rel.core.TableScan scan, org.apache.calcite.tools.RelBuilder relBuilder) Resolves filters using the underlying sources SupportsFilterPushDown and creates a new TableSourceTable with the supplied predicates.

从类继承的方法 org.apache.calcite.plan.RelOptRule

any, convert, convert, convertList, convertOperand, convertOperand, equals, equals, getOperand, getOperands, getOutConvention, getOutTrait, hashCode, none, onMatch, operand, operand, operand, operand, operand, operandJ, operandJ, some, toString, unordered

从类继承的方法 java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

构造器详细资料

PushFilterIntoSourceScanRuleBase

public PushFilterIntoSourceScanRuleBase(org.apache.calcite.plan.RelOptRuleOperand operand,
                                        String description)

方法详细资料

matches

public boolean matches(org.apache.calcite.plan.RelOptRuleCall call)

覆盖:

matches 在类中 org.apache.calcite.plan.RelOptRule

convertExpressionToRexNode

protected List<org.apache.calcite.rex.RexNode> convertExpressionToRexNode(List<org.apache.flink.table.expressions.ResolvedExpression> expressions,
                                                                          org.apache.calcite.tools.RelBuilder relBuilder)

createRemainingCondition

protected org.apache.calcite.rex.RexNode createRemainingCondition(org.apache.calcite.tools.RelBuilder relBuilder,
                                                                  List<org.apache.flink.table.expressions.ResolvedExpression> expressions,
                                                                  org.apache.calcite.rex.RexNode[] unconvertedPredicates)

resolveFiltersAndCreateTableSourceTable

protected scala.Tuple2<org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown.Result,org.apache.flink.table.planner.plan.schema.TableSourceTable> resolveFiltersAndCreateTableSourceTable(org.apache.calcite.rex.RexNode[] convertiblePredicates,
                                                                                                                                                                                                            org.apache.flink.table.planner.plan.schema.TableSourceTable oldTableSourceTable,
                                                                                                                                                                                                            org.apache.calcite.rel.core.TableScan scan,
                                                                                                                                                                                                            org.apache.calcite.tools.RelBuilder relBuilder)

Resolves filters using the underlying sources SupportsFilterPushDown and creates a new TableSourceTable with the supplied predicates.

参数:

convertiblePredicates - Predicates to resolve

oldTableSourceTable - TableSourceTable to copy

scan - Underlying table scan to push to

relBuilder - Builder to push the scan to

返回:

A tuple, constituting of the resolved filters and the newly created TableSourceTable

extractPredicates

protected scala.Tuple2<org.apache.calcite.rex.RexNode[],org.apache.calcite.rex.RexNode[]> extractPredicates(String[] inputNames,
                                                                                                            org.apache.calcite.rex.RexNode filterExpression,
                                                                                                            org.apache.calcite.rel.core.TableScan scan,
                                                                                                            org.apache.calcite.rex.RexBuilder rexBuilder)

canPushdownFilter

protected boolean canPushdownFilter(org.apache.flink.table.planner.plan.schema.TableSourceTable tableSourceTable)

Determines wether we can pushdown the filter into the source. we can not push filter twice, make sure FilterPushDownSpec has not been assigned as a capability.

参数:

tableSourceTable - Table scan to attempt to push into

返回:

Whether we can push or not

getNewFlinkStatistic

protected org.apache.flink.table.planner.plan.stats.FlinkStatistic getNewFlinkStatistic(org.apache.flink.table.planner.plan.schema.TableSourceTable tableSourceTable,
                                                                                        int originPredicatesSize,
                                                                                        int updatedPredicatesSize)