public class DataStreamOverAggregate extends org.apache.calcite.rel.SingleRel implements OverAggregate, DataStreamRel, Logging
Constructor and Description |
---|
DataStreamOverAggregate(org.apache.calcite.rel.core.Window logicWindow,
org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode inputNode,
RowSchema schema,
RowSchema inputSchema) |
Modifier and Type | Method and Description |
---|---|
boolean |
consumesRetractions()
Whether the
DataStreamRel consumes retraction messages instead of forwarding them. |
org.apache.calcite.rel.RelNode |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
List<org.apache.calcite.rel.RelNode> inputs) |
DataStream<CRow> |
createBoundedAndCurrentRowOverWindow(StreamQueryConfig queryConfig,
CodeGenerator generator,
DataStream<CRow> inputDS,
boolean isRowTimeType,
boolean isRowsClause) |
DataStream<CRow> |
createUnboundedAndCurrentRowOverWindow(StreamQueryConfig queryConfig,
CodeGenerator generator,
DataStream<CRow> inputDS,
boolean isRowTimeType,
boolean isRowsClause) |
org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter pw) |
boolean |
needsUpdatesAsRetraction()
Whether the
DataStreamRel requires that update and delete changes are sent with retraction
messages. |
String |
toString() |
DataStream<CRow> |
translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig)
Translates the FlinkRelNode into a Flink operator.
|
childrenAccept, estimateRowCount, getInput, getInputs, replaceInput
accept, accept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, computeSelfCost, explain, getChildExps, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, sole
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
aggregationToString, getLowerBoundary, orderingToString, partitionToString, windowRange
producesUpdates
estimateDataTypeSize, estimateRowSize, getExpressionString
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, 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 org.apache.calcite.rel.type.RelDataType deriveRowType()
deriveRowType
in class org.apache.calcite.rel.SingleRel
public boolean needsUpdatesAsRetraction()
DataStreamRel
DataStreamRel
requires that update and delete changes are sent with retraction
messages.needsUpdatesAsRetraction
in interface DataStreamRel
public boolean consumesRetractions()
DataStreamRel
DataStreamRel
consumes retraction messages instead of forwarding them.
The node might or might not produce new retraction messages.consumesRetractions
in interface DataStreamRel
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 String toString()
toString
in class org.apache.calcite.rel.AbstractRelNode
public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)
explainTerms
in class org.apache.calcite.rel.SingleRel
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
public DataStream<CRow> createUnboundedAndCurrentRowOverWindow(StreamQueryConfig queryConfig, CodeGenerator generator, DataStream<CRow> inputDS, boolean isRowTimeType, boolean isRowsClause)
public DataStream<CRow> createBoundedAndCurrentRowOverWindow(StreamQueryConfig queryConfig, CodeGenerator generator, DataStream<CRow> inputDS, boolean isRowTimeType, boolean isRowsClause)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.