public class FlinkLogicalTableSourceScan extends org.apache.calcite.rel.core.TableScan implements FlinkLogicalRel
Constructor and Description |
---|
FlinkLogicalTableSourceScan(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.plan.RelOptTable table,
TableSource<?> tableSource) |
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 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 metadata) |
static FlinkLogicalTableSourceScanConverter |
CONVERTER() |
FlinkLogicalTableSourceScan |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
TableSource<?> tableSource) |
org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
static double |
estimateDataTypeSize(org.apache.calcite.rel.type.RelDataType t) |
static double |
estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery x$1) |
static double |
estimateRowSize(org.apache.calcite.rel.type.RelDataType rowType) |
static void |
explain(org.apache.calcite.rel.RelWriter x$1) |
org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter pw) |
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(int x$1) |
static List<org.apache.calcite.rel.RelNode> |
getInputs() |
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 org.apache.calcite.util.ImmutableIntList |
identity() |
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 org.apache.calcite.rel.RelNode |
project(org.apache.calcite.util.ImmutableBitSet x$1,
Set<org.apache.calcite.rel.type.RelDataTypeField> x$2,
org.apache.calcite.tools.RelBuilder x$3) |
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) |
Object |
tableSource() |
String |
toString() |
accept, estimateRowCount, getCollationList, getTable, identity, identity, project
accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, copy, explain, getChildExps, getCluster, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput, sole
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
estimateDataTypeSize, estimateRowSize, getExpressionString
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, copy, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput
public FlinkLogicalTableSourceScan(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.plan.RelOptTable table, TableSource<?> tableSource)
public static FlinkLogicalTableSourceScanConverter 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(org.apache.calcite.util.Litmus x$1, org.apache.calcite.rel.RelNode.Context x$2)
public static boolean isValid(boolean x$1)
public static final org.apache.calcite.rel.type.RelDataType getRowType()
public static org.apache.calcite.rel.type.RelDataType getExpectedInputRowType(int x$1)
public static List<org.apache.calcite.rel.RelNode> getInputs()
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 void childrenAccept(org.apache.calcite.rel.RelVisitor x$1)
public static org.apache.calcite.rel.RelNode accept(org.apache.calcite.rex.RexShuttle 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 void replaceInput(int x$1, org.apache.calcite.rel.RelNode x$2)
public static final String getDescription()
public static final String getDigest()
protected static String computeDigest()
public static double estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery x$1)
public static org.apache.calcite.plan.RelOptTable getTable()
public static List<org.apache.calcite.rel.RelCollation> getCollationList()
public static org.apache.calcite.util.ImmutableIntList identity()
public static org.apache.calcite.rel.RelNode project(org.apache.calcite.util.ImmutableBitSet x$1, Set<org.apache.calcite.rel.type.RelDataTypeField> x$2, org.apache.calcite.tools.RelBuilder x$3)
public static org.apache.calcite.rel.RelNode accept(org.apache.calcite.rel.RelShuttle 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 Object tableSource()
public FlinkLogicalTableSourceScan copy(org.apache.calcite.plan.RelTraitSet traitSet, TableSource<?> tableSource)
public org.apache.calcite.rel.type.RelDataType deriveRowType()
deriveRowType
in class org.apache.calcite.rel.core.TableScan
public org.apache.calcite.plan.RelOptCost computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery metadata)
computeSelfCost
in interface org.apache.calcite.rel.RelNode
computeSelfCost
in class org.apache.calcite.rel.core.TableScan
public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)
explainTerms
in class org.apache.calcite.rel.core.TableScan
public String toString()
toString
in class org.apache.calcite.rel.AbstractRelNode
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.