public class FlinkLogicalCalc extends org.apache.calcite.rel.core.Calc implements FlinkLogicalRel, CommonCalc
Constructor and Description |
---|
FlinkLogicalCalc(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode input,
org.apache.calcite.rex.RexProgram calcProgram) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
accept(org.apache.calcite.rel.RelShuttle x$1) |
static org.apache.calcite.rel.RelNode |
accept(org.apache.calcite.rex.RexShuttle x$1) |
static String |
calcOpName(org.apache.calcite.rex.RexProgram calcProgram,
scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression) |
static String |
calcToString(org.apache.calcite.rex.RexProgram calcProgram,
scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression) |
static void |
childrenAccept(org.apache.calcite.rel.RelVisitor x$1) |
static void |
collectVariablesSet(Set<org.apache.calcite.rel.core.CorrelationId> x$1) |
static void |
collectVariablesUsed(Set<org.apache.calcite.rel.core.CorrelationId> x$1) |
protected static String |
computeDigest() |
org.apache.calcite.plan.RelOptCost |
computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner,
org.apache.calcite.rel.metadata.RelMetadataQuery mq) |
static String |
conditionToString(org.apache.calcite.rex.RexProgram calcProgram,
scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression) |
static org.apache.calcite.rel.convert.ConverterRule |
CONVERTER() |
org.apache.calcite.rel.core.Calc |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode child,
org.apache.calcite.rex.RexProgram program) |
protected static org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
static double |
estimateDataTypeSize(org.apache.calcite.rel.type.RelDataType t) |
double |
estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery metadata) |
static double |
estimateRowSize(org.apache.calcite.rel.type.RelDataType rowType) |
static void |
explain(org.apache.calcite.rel.RelWriter x$1) |
static org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter x$1) |
static <T extends Function> |
generateFunction(CodeGenerator generator,
String ruleDescription,
RowSchema inputSchema,
RowSchema returnSchema,
org.apache.calcite.rex.RexProgram calcProgram,
TableConfig config,
Class<T> functionClass) |
static List<org.apache.calcite.rex.RexNode> |
getChildExps() |
static org.apache.calcite.plan.RelOptCluster |
getCluster() |
static List<org.apache.calcite.rel.RelCollation> |
getCollationList() |
static org.apache.calcite.plan.Convention |
getConvention() |
static String |
getCorrelVariable() |
static String |
getDescription() |
static String |
getDigest() |
static org.apache.calcite.rel.type.RelDataType |
getExpectedInputRowType(int x$1) |
static String |
getExpressionString(org.apache.calcite.rex.RexNode expr,
scala.collection.immutable.List<String> inFields,
scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>> localExprsTable) |
static int |
getId() |
static org.apache.calcite.rel.RelNode |
getInput() |
static org.apache.calcite.rel.RelNode |
getInput(int x$1) |
static List<org.apache.calcite.rel.RelNode> |
getInputs() |
static org.apache.calcite.rex.RexProgram |
getProgram() |
static org.apache.calcite.plan.RelOptQuery |
getQuery() |
static String |
getRelTypeName() |
static double |
getRows() |
static org.apache.calcite.rel.type.RelDataType |
getRowType() |
static org.apache.calcite.plan.RelOptTable |
getTable() |
static org.apache.calcite.plan.RelTraitSet |
getTraitSet() |
static Set<org.apache.calcite.rel.core.CorrelationId> |
getVariablesSet() |
static Set<String> |
getVariablesStopped() |
static boolean |
isDistinct() |
static boolean |
isKey(org.apache.calcite.util.ImmutableBitSet x$1) |
static boolean |
isValid(boolean x$1) |
static boolean |
isValid(org.apache.calcite.util.Litmus x$1,
org.apache.calcite.rel.RelNode.Context x$2) |
static <M extends org.apache.calcite.rel.metadata.Metadata> |
metadata(Class<M> x$1,
org.apache.calcite.rel.metadata.RelMetadataQuery x$2) |
static org.apache.calcite.rel.RelNode |
onRegister(org.apache.calcite.plan.RelOptPlanner x$1) |
static String |
recomputeDigest() |
static void |
register(org.apache.calcite.plan.RelOptPlanner x$1) |
static void |
replaceInput(int x$1,
org.apache.calcite.rel.RelNode x$2) |
static String |
selectionToString(org.apache.calcite.rex.RexProgram calcProgram,
scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression) |
static String |
toString() |
accept, copy, copy, explainTerms, getProgram, isValid
childrenAccept, deriveRowType, getInput, getInputs, replaceInput
accept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, explain, getChildExps, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, metadata, onRegister, recomputeDigest, register, sole, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
estimateDataTypeSize, estimateRowSize, getExpressionString
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, copy, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput
getCluster, getDescription, getDigest, getId, getTraitSet
calcOpName, calcToString, computeSelfCost, conditionToString, estimateRowCount, generateFunction, selectionToString
public FlinkLogicalCalc(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode input, org.apache.calcite.rex.RexProgram calcProgram)
public static org.apache.calcite.rel.convert.ConverterRule CONVERTER()
public static List<org.apache.calcite.rex.RexNode> getChildExps()
public static final org.apache.calcite.plan.RelOptCluster getCluster()
public static final org.apache.calcite.plan.Convention getConvention()
public static org.apache.calcite.plan.RelTraitSet getTraitSet()
public static String getCorrelVariable()
public static boolean isDistinct()
public static boolean isKey(org.apache.calcite.util.ImmutableBitSet x$1)
public static int getId()
public static org.apache.calcite.rel.RelNode getInput(int x$1)
public static final org.apache.calcite.plan.RelOptQuery getQuery()
public static void register(org.apache.calcite.plan.RelOptPlanner x$1)
public static final String getRelTypeName()
public static boolean isValid(boolean x$1)
public static List<org.apache.calcite.rel.RelCollation> getCollationList()
public static final org.apache.calcite.rel.type.RelDataType getRowType()
public static org.apache.calcite.rel.type.RelDataType getExpectedInputRowType(int x$1)
public static final double getRows()
public static Set<org.apache.calcite.rel.core.CorrelationId> getVariablesSet()
public static void collectVariablesUsed(Set<org.apache.calcite.rel.core.CorrelationId> x$1)
public static void collectVariablesSet(Set<org.apache.calcite.rel.core.CorrelationId> x$1)
public static org.apache.calcite.rel.RelNode accept(org.apache.calcite.rel.RelShuttle x$1)
public static final <M extends org.apache.calcite.rel.metadata.Metadata> M metadata(Class<M> x$1, org.apache.calcite.rel.metadata.RelMetadataQuery x$2)
public static void explain(org.apache.calcite.rel.RelWriter x$1)
public static org.apache.calcite.rel.RelNode onRegister(org.apache.calcite.plan.RelOptPlanner x$1)
public static String recomputeDigest()
public static String toString()
public static final String getDescription()
public static final String getDigest()
public static org.apache.calcite.plan.RelOptTable getTable()
protected static String computeDigest()
public static org.apache.calcite.rel.RelNode getInput()
public static List<org.apache.calcite.rel.RelNode> getInputs()
public static void childrenAccept(org.apache.calcite.rel.RelVisitor x$1)
public static void replaceInput(int x$1, org.apache.calcite.rel.RelNode x$2)
protected static org.apache.calcite.rel.type.RelDataType deriveRowType()
public static boolean isValid(org.apache.calcite.util.Litmus x$1, org.apache.calcite.rel.RelNode.Context x$2)
public static org.apache.calcite.rex.RexProgram getProgram()
public static org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter x$1)
public static org.apache.calcite.rel.RelNode accept(org.apache.calcite.rex.RexShuttle x$1)
public static String getExpressionString(org.apache.calcite.rex.RexNode expr, scala.collection.immutable.List<String> inFields, scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>> localExprsTable)
public static double estimateRowSize(org.apache.calcite.rel.type.RelDataType rowType)
public static double estimateDataTypeSize(org.apache.calcite.rel.type.RelDataType t)
public static <T extends Function> GeneratedFunction<T,Row> generateFunction(CodeGenerator generator, String ruleDescription, RowSchema inputSchema, RowSchema returnSchema, org.apache.calcite.rex.RexProgram calcProgram, TableConfig config, Class<T> functionClass)
public static String conditionToString(org.apache.calcite.rex.RexProgram calcProgram, scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression)
public static String selectionToString(org.apache.calcite.rex.RexProgram calcProgram, scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression)
public static String calcOpName(org.apache.calcite.rex.RexProgram calcProgram, scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression)
public static String calcToString(org.apache.calcite.rex.RexProgram calcProgram, scala.Function3<org.apache.calcite.rex.RexNode,scala.collection.immutable.List<String>,scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>>,String> expression)
public org.apache.calcite.rel.core.Calc copy(org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode child, org.apache.calcite.rex.RexProgram program)
copy
in class org.apache.calcite.rel.core.Calc
public org.apache.calcite.plan.RelOptCost computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
computeSelfCost
in interface org.apache.calcite.rel.RelNode
computeSelfCost
in class org.apache.calcite.rel.core.Calc
public double estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery metadata)
estimateRowCount
in interface org.apache.calcite.rel.RelNode
estimateRowCount
in class org.apache.calcite.rel.core.Calc
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.