Modifier and Type | Method and Description |
---|---|
org.apache.calcite.tools.RelBuilder |
FlinkRelBuilder.aggregate(LogicalWindow window,
org.apache.calcite.tools.RelBuilder.GroupKey groupKey,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties,
Iterable<org.apache.calcite.tools.RelBuilder.AggCall> aggCalls) |
Modifier and Type | Method and Description |
---|---|
static FlinkRelBuilder.NamedWindowProperty |
WindowStart.toNamedWindowProperty(String name) |
FlinkRelBuilder.NamedWindowProperty |
AbstractWindowProperty.toNamedWindowProperty(String name) |
FlinkRelBuilder.NamedWindowProperty |
ProctimeAttribute.toNamedWindowProperty(String name) |
FlinkRelBuilder.NamedWindowProperty |
WindowProperty.toNamedWindowProperty(String name) |
static FlinkRelBuilder.NamedWindowProperty |
WindowEnd.toNamedWindowProperty(String name) |
FlinkRelBuilder.NamedWindowProperty |
RowtimeAttribute.toNamedWindowProperty(String name) |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> |
LogicalWindowAggregate.getNamedProperties() |
Modifier and Type | Method and Description |
---|---|
static LogicalWindowAggregate |
LogicalWindowAggregate.create(LogicalWindow window,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties,
org.apache.calcite.rel.core.Aggregate aggregate) |
LogicalWindowAggregate |
LogicalWindowAggregate$.create(LogicalWindow window,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> namedProperties,
org.apache.calcite.rel.core.Aggregate aggregate) |
Constructor and Description |
---|
LogicalWindowAggregate(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 child,
boolean indicator,
org.apache.calcite.util.ImmutableBitSet groupSet,
List<org.apache.calcite.util.ImmutableBitSet> groupSets,
List<org.apache.calcite.rel.core.AggregateCall> aggCalls) |
Modifier and Type | Method and Description |
---|---|
String |
CommonAggregate.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) |
Constructor and Description |
---|
DataSetWindowAggregate(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,
org.apache.calcite.rel.type.RelDataType rowRelDataType,
org.apache.calcite.rel.type.RelDataType inputType,
int[] grouping) |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> |
DataStreamGroupWindowAggregate.getWindowProperties() |
Modifier and Type | Method and Description |
---|---|
static String |
DataStreamGroupWindowAggregate.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) |
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 |
---|---|
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> |
FlinkLogicalWindowAggregate.getNamedProperties() |
Constructor and Description |
---|
FlinkLogicalWindowAggregate(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 child,
boolean indicator,
org.apache.calcite.util.ImmutableBitSet groupSet,
List<org.apache.calcite.util.ImmutableBitSet> groupSets,
List<org.apache.calcite.rel.core.AggregateCall> aggCalls) |
Modifier and Type | Method and Description |
---|---|
static scala.Tuple2<scala.Option<Object>,scala.Option<Object>> |
AggregateUtil.computeWindowStartEndPropertyPos(scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties) |
scala.Tuple2<scala.Option<Object>,scala.Option<Object>> |
AggregateUtil$.computeWindowStartEndPropertyPos(scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties) |
static AllWindowFunction<Row,CRow,Window> |
AggregateUtil.createAggregationAllWindowFunction(LogicalWindow window,
int finalRowArity,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction for non-partitioned window aggregates. |
AllWindowFunction<Row,CRow,Window> |
AggregateUtil$.createAggregationAllWindowFunction(LogicalWindow window,
int finalRowArity,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction for non-partitioned window aggregates. |
static WindowFunction<Row,CRow,Tuple,Window> |
AggregateUtil.createAggregationGroupWindowFunction(LogicalWindow window,
int numGroupingKeys,
int numAggregates,
int finalRowArity,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction for group window aggregates. |
WindowFunction<Row,CRow,Tuple,Window> |
AggregateUtil$.createAggregationGroupWindowFunction(LogicalWindow window,
int numGroupingKeys,
int numAggregates,
int finalRowArity,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction for group window aggregates. |
static RichGroupReduceFunction<Row,Row> |
AggregateUtil.createDataSetWindowAggregationGroupReduceFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties,
boolean isInputCombined)
Create a
GroupReduceFunction to compute window
aggregates on batch tables. |
RichGroupReduceFunction<Row,Row> |
AggregateUtil$.createDataSetWindowAggregationGroupReduceFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties,
boolean isInputCombined)
Create a
GroupReduceFunction to compute window
aggregates on batch tables. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.