public abstract class BatchScan extends org.apache.calcite.rel.core.TableScan implements DataSetRel
Constructor and Description |
---|
BatchScan(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.plan.RelOptTable table,
org.apache.calcite.rel.type.RelDataType rowType) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.plan.RelOptCost |
computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner,
org.apache.calcite.rel.metadata.RelMetadataQuery metadata) |
protected DataSet<Object> |
convertToExpectedType(DataSet<Object> input,
FlinkTable<?> flinkTable,
scala.Option<TypeInformation<Object>> expectedType,
TableConfig config) |
org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
String |
toString() |
accept, estimateRowCount, explainTerms, 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
estimateRowSize, getConversionMapper, translateToPlan
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
getCluster, getDescription, getDigest, getId, getTraitSet
getExpressionString
public BatchScan(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.plan.RelOptTable table, org.apache.calcite.rel.type.RelDataType rowType)
public org.apache.calcite.rel.type.RelDataType deriveRowType()
deriveRowType
in class org.apache.calcite.rel.core.TableScan
public String toString()
toString
in class org.apache.calcite.rel.AbstractRelNode
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
protected DataSet<Object> convertToExpectedType(DataSet<Object> input, FlinkTable<?> flinkTable, scala.Option<TypeInformation<Object>> expectedType, TableConfig config)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.