public class StreamTableSourceScan extends PhysicalTableSourceScan implements StreamScan
StreamTableSource
.Constructor and Description |
---|
StreamTableSourceScan(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.plan.RelOptTable table,
StreamTableSource<?> tableSource) |
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) |
org.apache.calcite.rel.RelNode |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
List<org.apache.calcite.rel.RelNode> inputs) |
PhysicalTableSourceScan |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
TableSource<?> newTableSource) |
org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
DataStream<CRow> |
translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig)
Translates the FlinkRelNode into a Flink operator.
|
explainTerms, tableSource, toString
accept, estimateRowCount, 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
convertToInternalRow
generatedConversionFunction, needsConversion
consumesRetractions, needsUpdatesAsRetraction, producesUpdates
estimateDataTypeSize, estimateRowSize, getExpressionString
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
public StreamTableSourceScan(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.plan.RelOptTable table, StreamTableSource<?> tableSource)
public org.apache.calcite.rel.type.RelDataType deriveRowType()
deriveRowType
in class PhysicalTableSourceScan
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.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 PhysicalTableSourceScan copy(org.apache.calcite.plan.RelTraitSet traitSet, TableSource<?> newTableSource)
copy
in class PhysicalTableSourceScan
public DataStream<CRow> translateToPlan(StreamTableEnvironment tableEnv, StreamQueryConfig queryConfig)
DataStreamRel
translateToPlan
in interface DataStreamRel
tableEnv
- The StreamTableEnvironment
of the translated Table.queryConfig
- The configuration for the query to generate.CRow
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.