public class DataStreamGroupAggregate extends org.apache.calcite.rel.SingleRel implements CommonAggregate, DataStreamRel, Logging
param: cluster Cluster of the RelNode, represent for an environment of related relational expressions during the optimization of a query. param: traitSet Trait set of the RelNode param: inputNode The input RelNode of aggregation param: namedAggregates List of calls to aggregate functions and their output field names param: inputSchema The type of the rows consumed by this RelNode param: schema The type of the rows emitted by this RelNode param: groupings The position (in the input Row) of the grouping keys
Constructor and Description |
---|
DataStreamGroupAggregate(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode inputNode,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
RowSchema schema,
RowSchema inputSchema,
int[] groupings) |
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) |
org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter pw) |
int[] |
getGroupings() |
boolean |
needsUpdatesAsRetraction()
Whether the
DataStreamRel requires that update and delete changes are sent with retraction
messages. |
boolean |
producesUpdates()
Whether the
DataStreamRel produces update and delete changes. |
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, groupingToString
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 DataStreamGroupAggregate(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode inputNode, scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates, RowSchema schema, RowSchema inputSchema, int[] groupings)
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 producesUpdates()
DataStreamRel
DataStreamRel
produces update and delete changes.producesUpdates
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 int[] getGroupings()
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
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.