org.apache.flink.table.planner.plan.nodes.physical.common

Class CommonPhysicalMatch

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.calcite.rel.SingleRel

org.apache.flink.table.planner.plan.nodes.physical.common.CommonPhysicalMatch

All Implemented Interfaces:

Cloneable, org.apache.calcite.plan.RelOptNode, org.apache.calcite.rel.RelNode, org.apache.flink.table.planner.plan.nodes.FlinkRelNode, org.apache.flink.table.planner.plan.nodes.physical.FlinkPhysicalRel

Direct Known Subclasses:

BatchPhysicalMatch

public abstract class CommonPhysicalMatch
extends org.apache.calcite.rel.SingleRel
implements org.apache.flink.table.planner.plan.nodes.physical.FlinkPhysicalRel

Base physical RelNode which matches along with MATCH_RECOGNIZE.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.rel.RelNode

org.apache.calcite.rel.RelNode.Context

Field Summary

Fields inherited from class org.apache.calcite.rel.SingleRel

input

Fields inherited from class org.apache.calcite.rel.AbstractRelNode

digest, id, rowType, traitSet

Constructor Summary

Constructors

Constructor and Description
CommonPhysicalMatch(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode inputNode, org.apache.flink.table.planner.plan.logical.MatchRecognize logicalMatch, org.apache.calcite.rel.type.RelDataType outputRowType)

Method Summary

Modifier and Type	Method and Description
protected org.apache.calcite.rel.type.RelDataType	deriveRowType()
org.apache.calcite.rel.RelWriter	explainTerms(org.apache.calcite.rel.RelWriter pw)
org.apache.flink.table.planner.plan.logical.MatchRecognize	getLogicalMatch()

Methods inherited from class org.apache.calcite.rel.SingleRel

childrenAccept, estimateRowCount, getInput, getInputs, replaceInput

Methods inherited from class org.apache.calcite.rel.AbstractRelNode

accept, accept, collectVariablesSet, collectVariablesUsed, computeSelfCost, copy, deepEquals, deepHashCode, equals, explain, getCluster, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getRelDigest, getRelTypeName, getRowType, getTable, getTraitSet, getVariablesSet, hashCode, isEnforcer, isValid, metadata, onRegister, recomputeDigest, register, sole, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.physical.FlinkPhysicalRel

$init$, satisfyTraits, translateToExecNode, translateToExecNode

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.FlinkRelNode

$init$, convertToExpressionDetail, getExpressionString, getExpressionString, getExpressionString, getExpressionString, getRelDetailedDescription

Methods inherited from interface org.apache.calcite.rel.RelNode

accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, copy, deepEquals, deepHashCode, estimateRowCount, explain, explain, fieldIsNullable, getConvention, getCorrelVariable, getDigest, getExpectedInputRowType, getInput, getInputs, getRelDigest, getRelTypeName, getRowType, getTable, getVariablesSet, isEnforcer, isValid, metadata, onRegister, recomputeDigest, register, replaceInput

Methods inherited from interface org.apache.calcite.plan.RelOptNode

getCluster, getDescription, getId, getTraitSet

Constructor Detail

CommonPhysicalMatch

public CommonPhysicalMatch(org.apache.calcite.plan.RelOptCluster cluster,
                           org.apache.calcite.plan.RelTraitSet traitSet,
                           org.apache.calcite.rel.RelNode inputNode,
                           org.apache.flink.table.planner.plan.logical.MatchRecognize logicalMatch,
                           org.apache.calcite.rel.type.RelDataType outputRowType)

Method Detail

deriveRowType

protected org.apache.calcite.rel.type.RelDataType deriveRowType()

Overrides:

deriveRowType in class org.apache.calcite.rel.SingleRel

explainTerms

public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)

Overrides:

explainTerms in class org.apache.calcite.rel.SingleRel

getLogicalMatch

public org.apache.flink.table.planner.plan.logical.MatchRecognize getLogicalMatch()