public class BatchTableSourceScan extends BatchScan
BatchTableSource
.Constructor and Description |
---|
BatchTableSourceScan(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.rel.RelNode |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
List<org.apache.calcite.rel.RelNode> inputs) |
Object |
tableSource() |
TableSourceTable |
tableSourceTable() |
DataSet<Object> |
translateToPlan(BatchTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType)
Translates the
DataSetRel node into a DataSet operator. |
computeSelfCost, convertToExpectedType, deriveRowType, toString
accept, estimateRowCount, explainTerms, getCollationList, getTable, identity, identity, project
accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, 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
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, 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 BatchTableSourceScan(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 TableSourceTable tableSourceTable()
public Object tableSource()
public org.apache.calcite.rel.RelNode copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
copy
in interface org.apache.calcite.rel.RelNode
copy
in class org.apache.calcite.rel.AbstractRelNode
public DataSet<Object> translateToPlan(BatchTableEnvironment tableEnv, scala.Option<TypeInformation<Object>> expectedType)
DataSetRel
DataSetRel
node into a DataSet
operator.
tableEnv
- BatchTableEnvironment
of the translated Table.expectedType
- specifies the type the Flink operator should return. The type must
have the same arity as the result. For instance, if the
expected type is a RowTypeInfo this method will return a DataSet of
type Row. If the expected type is Tuple2, the operator will return
a Tuple2 if possible. Row otherwise.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.