public abstract class AbstractPythonCorrelateRuleBase
extends org.apache.calcite.rel.convert.ConverterRule
FlinkLogicalCorrelate
to
physical Python correlate RelNode.Modifier and Type | Class and Description |
---|---|
static class |
AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase
The abstract factory is responsible for creating
DataSetPythonCorrelate or DataStreamPythonCorrelate . |
Constructor and Description |
---|
AbstractPythonCorrelateRuleBase(org.apache.calcite.plan.Convention physicalConvention,
String description) |
Modifier and Type | Method and Description |
---|---|
boolean |
matches(org.apache.calcite.plan.RelOptRuleCall call) |
convert, getInTrait, getOutConvention, getOutTrait, getTraitDef, isGuaranteed, onMatch
public AbstractPythonCorrelateRuleBase(org.apache.calcite.plan.Convention physicalConvention, String description)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.