public abstract class StreamScan extends org.apache.calcite.rel.core.TableScan implements DataStreamRel
Constructor and Description |
---|
StreamScan(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 |
---|---|
protected DataStream<Object> |
convertToExpectedType(DataStream<Object> input,
FlinkTable<?> flinkTable,
scala.Option<TypeInformation<Object>> expectedType,
TableConfig config) |
org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
accept, computeSelfCost, 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, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
translateToPlan
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, 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 StreamScan(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
protected DataStream<Object> convertToExpectedType(DataStream<Object> input, FlinkTable<?> flinkTable, scala.Option<TypeInformation<Object>> expectedType, TableConfig config)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.