Modifier and Type | Method and Description |
---|---|
LogicalWindow |
TumblingWindow.toLogicalWindow() |
LogicalWindow |
TumblingEventTimeWindow.toLogicalWindow() |
LogicalWindow |
SessionEventTimeWindow.toLogicalWindow() |
LogicalWindow |
SlidingEventTimeWindow.toLogicalWindow() |
abstract LogicalWindow |
Window.toLogicalWindow()
Converts an API class to a logical window for planning.
|
LogicalWindow |
SlidingWindow.toLogicalWindow() |
LogicalWindow |
SessionWindow.toLogicalWindow() |
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 | Class and Description |
---|---|
class |
EventTimeGroupWindow |
class |
EventTimeSessionGroupWindow |
class |
EventTimeSlidingGroupWindow |
class |
EventTimeTumblingGroupWindow |
class |
ProcessingTimeGroupWindow |
class |
ProcessingTimeSessionGroupWindow |
class |
ProcessingTimeSlidingGroupWindow |
class |
ProcessingTimeTumblingGroupWindow |
Modifier and Type | Method and Description |
---|---|
LogicalWindow |
EventTimeSlidingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
ProcessingTimeSessionGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
ProcessingTimeSlidingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
LogicalWindow.resolveExpressions(scala.Function1<Expression,Expression> resolver) |
LogicalWindow |
EventTimeTumblingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
EventTimeSessionGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
ProcessingTimeTumblingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
WindowAggregate.window() |
Constructor and Description |
---|
WindowAggregate(scala.collection.Seq<Expression> groupingExpressions,
LogicalWindow window,
scala.collection.Seq<NamedExpression> propertyExpressions,
scala.collection.Seq<NamedExpression> aggregateExpressions,
LogicalNode child) |
Modifier and Type | Method and Description |
---|---|
LogicalWindow |
LogicalWindowAggregate.getWindow() |
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) |
Constructor and Description |
---|
DataStreamAggregate(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 |
---|---|
static AllWindowFunction<Row,Row,Window> |
AggregateUtil.createAllWindowAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction to compute non-partitioned group window aggregates. |
AllWindowFunction<Row,Row,Window> |
AggregateUtil$.createAllWindowAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction to compute non-partitioned group window aggregates. |
static AllWindowFunction<Row,Row,Window> |
AggregateUtil.createAllWindowIncrementalAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction to finalize incrementally pre-computed non-partitioned
window aggreagtes. |
AllWindowFunction<Row,Row,Window> |
AggregateUtil$.createAllWindowIncrementalAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction to finalize incrementally pre-computed non-partitioned
window aggreagtes. |
static WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil.createWindowAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to compute partitioned group window aggregates. |
WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil$.createWindowAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to compute partitioned group window aggregates. |
static WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil.createWindowIncrementalAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to finalize incrementally pre-computed window aggregates. |
WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil$.createWindowIncrementalAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to finalize incrementally pre-computed window aggregates. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.