public class DataStreamGroupWindowAggregate extends org.apache.calcite.rel.SingleRel implements CommonAggregate, DataStreamRel, Logging
Constructor and Description |
---|
DataStreamGroupWindowAggregate(LogicalWindow window,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties,
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[] grouping) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
accept(org.apache.calcite.rel.RelShuttle x$1) |
static org.apache.calcite.rel.RelNode |
accept(org.apache.calcite.rex.RexShuttle x$1) |
static String |
aggregationToString(org.apache.calcite.rel.type.RelDataType inputType,
int[] grouping,
org.apache.calcite.rel.type.RelDataType rowType,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties) |
static void |
childrenAccept(org.apache.calcite.rel.RelVisitor x$1) |
static void |
collectVariablesSet(Set<org.apache.calcite.rel.core.CorrelationId> x$1) |
static void |
collectVariablesUsed(Set<org.apache.calcite.rel.core.CorrelationId> x$1) |
protected static String |
computeDigest() |
static org.apache.calcite.plan.RelOptCost |
computeSelfCost(org.apache.calcite.plan.RelOptPlanner x$1) |
static org.apache.calcite.plan.RelOptCost |
computeSelfCost(org.apache.calcite.plan.RelOptPlanner x$1,
org.apache.calcite.rel.metadata.RelMetadataQuery x$2) |
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() |
static double |
estimateDataTypeSize(org.apache.calcite.rel.type.RelDataType t) |
static double |
estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery x$1) |
static double |
estimateRowSize(org.apache.calcite.rel.type.RelDataType rowType) |
static void |
explain(org.apache.calcite.rel.RelWriter x$1) |
org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter pw) |
static List<org.apache.calcite.rex.RexNode> |
getChildExps() |
static org.apache.calcite.plan.RelOptCluster |
getCluster() |
static List<org.apache.calcite.rel.RelCollation> |
getCollationList() |
static org.apache.calcite.plan.Convention |
getConvention() |
static String |
getCorrelVariable() |
static String |
getDescription() |
static String |
getDigest() |
static org.apache.calcite.rel.type.RelDataType |
getExpectedInputRowType(int x$1) |
static String |
getExpressionString(org.apache.calcite.rex.RexNode expr,
scala.collection.immutable.List<String> inFields,
scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>> localExprsTable) |
int[] |
getGroupings() |
static int |
getId() |
static org.apache.calcite.rel.RelNode |
getInput() |
static org.apache.calcite.rel.RelNode |
getInput(int x$1) |
static List<org.apache.calcite.rel.RelNode> |
getInputs() |
static org.apache.calcite.plan.RelOptQuery |
getQuery() |
static String |
getRelTypeName() |
static double |
getRows() |
static org.apache.calcite.rel.type.RelDataType |
getRowType() |
static org.apache.calcite.plan.RelOptTable |
getTable() |
static org.apache.calcite.plan.RelTraitSet |
getTraitSet() |
static Set<org.apache.calcite.rel.core.CorrelationId> |
getVariablesSet() |
static Set<String> |
getVariablesStopped() |
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> |
getWindowProperties() |
static String |
groupingToString(org.apache.calcite.rel.type.RelDataType inputType,
int[] grouping) |
static boolean |
isDistinct() |
static boolean |
isKey(org.apache.calcite.util.ImmutableBitSet x$1) |
static boolean |
isValid(boolean x$1) |
static boolean |
isValid(org.apache.calcite.util.Litmus x$1,
org.apache.calcite.rel.RelNode.Context x$2) |
static org.slf4j.Logger |
LOG() |
static <M extends org.apache.calcite.rel.metadata.Metadata> |
metadata(Class<M> x$1,
org.apache.calcite.rel.metadata.RelMetadataQuery x$2) |
boolean |
needsUpdatesAsRetraction()
Whether the
DataStreamRel requires that update and delete changes are sent with retraction
messages. |
static org.apache.calcite.rel.RelNode |
onRegister(org.apache.calcite.plan.RelOptPlanner x$1) |
static boolean |
producesUpdates() |
static String |
recomputeDigest() |
static void |
register(org.apache.calcite.plan.RelOptPlanner x$1) |
static void |
replaceInput(int x$1,
org.apache.calcite.rel.RelNode x$2) |
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
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 DataStreamGroupWindowAggregate(LogicalWindow window, scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties, 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[] grouping)
public static List<org.apache.calcite.rex.RexNode> getChildExps()
public static final org.apache.calcite.plan.RelOptCluster getCluster()
public static final org.apache.calcite.plan.Convention getConvention()
public static org.apache.calcite.plan.RelTraitSet getTraitSet()
public static String getCorrelVariable()
public static boolean isDistinct()
public static boolean isKey(org.apache.calcite.util.ImmutableBitSet x$1)
public static int getId()
public static org.apache.calcite.rel.RelNode getInput(int x$1)
public static final org.apache.calcite.plan.RelOptQuery getQuery()
public static void register(org.apache.calcite.plan.RelOptPlanner x$1)
public static final String getRelTypeName()
public static boolean isValid(org.apache.calcite.util.Litmus x$1, org.apache.calcite.rel.RelNode.Context x$2)
public static boolean isValid(boolean x$1)
public static List<org.apache.calcite.rel.RelCollation> getCollationList()
public static final org.apache.calcite.rel.type.RelDataType getRowType()
public static org.apache.calcite.rel.type.RelDataType getExpectedInputRowType(int x$1)
public static final double getRows()
public static Set<org.apache.calcite.rel.core.CorrelationId> getVariablesSet()
public static void collectVariablesUsed(Set<org.apache.calcite.rel.core.CorrelationId> x$1)
public static void collectVariablesSet(Set<org.apache.calcite.rel.core.CorrelationId> x$1)
public static org.apache.calcite.rel.RelNode accept(org.apache.calcite.rel.RelShuttle x$1)
public static org.apache.calcite.rel.RelNode accept(org.apache.calcite.rex.RexShuttle x$1)
public static final org.apache.calcite.plan.RelOptCost computeSelfCost(org.apache.calcite.plan.RelOptPlanner x$1)
public static org.apache.calcite.plan.RelOptCost computeSelfCost(org.apache.calcite.plan.RelOptPlanner x$1, org.apache.calcite.rel.metadata.RelMetadataQuery x$2)
public static final <M extends org.apache.calcite.rel.metadata.Metadata> M metadata(Class<M> x$1, org.apache.calcite.rel.metadata.RelMetadataQuery x$2)
public static void explain(org.apache.calcite.rel.RelWriter x$1)
public static org.apache.calcite.rel.RelNode onRegister(org.apache.calcite.plan.RelOptPlanner x$1)
public static String recomputeDigest()
public static final String getDescription()
public static final String getDigest()
public static org.apache.calcite.plan.RelOptTable getTable()
protected static String computeDigest()
public static org.apache.calcite.rel.RelNode getInput()
public static List<org.apache.calcite.rel.RelNode> getInputs()
public static double estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery x$1)
public static void childrenAccept(org.apache.calcite.rel.RelVisitor x$1)
public static void replaceInput(int x$1, org.apache.calcite.rel.RelNode x$2)
public static String groupingToString(org.apache.calcite.rel.type.RelDataType inputType, int[] grouping)
public static String aggregationToString(org.apache.calcite.rel.type.RelDataType inputType, int[] grouping, org.apache.calcite.rel.type.RelDataType rowType, scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates, scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties)
public static String getExpressionString(org.apache.calcite.rex.RexNode expr, scala.collection.immutable.List<String> inFields, scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>> localExprsTable)
public static double estimateRowSize(org.apache.calcite.rel.type.RelDataType rowType)
public static double estimateDataTypeSize(org.apache.calcite.rel.type.RelDataType t)
public static boolean producesUpdates()
public static org.slf4j.Logger LOG()
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 int[] getGroupings()
public scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> getWindowProperties()
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.