Modifier and Type | Method and Description |
---|---|
abstract LogicalWindow |
Window.toLogicalWindow()
Converts an API class to a logical window for planning.
|
LogicalWindow |
SessionWithGapOnTimeWithAlias.toLogicalWindow()
Converts an API class to a logical window for planning.
|
LogicalWindow |
TumbleWithSizeOnTimeWithAlias.toLogicalWindow()
Converts an API class to a logical window for planning.
|
LogicalWindow |
SlideWithSizeAndSlideOnTimeWithAlias.toLogicalWindow()
Converts an API class to a logical window for planning.
|
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 |
SessionGroupWindow |
class |
SlidingGroupWindow |
class |
TumblingGroupWindow |
Modifier and Type | Method and Description |
---|---|
LogicalWindow |
SessionGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
LogicalWindow.resolveExpressions(scala.Function1<Expression,Expression> resolver) |
LogicalWindow |
SlidingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
TumblingGroupWindow.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 |
---|
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) |
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 |
---|---|
LogicalWindow |
FlinkLogicalWindowAggregate.getWindow() |
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 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 FlatMapFunction<Row,Row> |
AggregateUtil.createDataSetSlideWindowPrepareFlatMapFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
TypeInformation<Row> inputType,
boolean isParserCaseSensitive)
Create a
FlatMapFunction that prepares for
non-incremental aggregates of sliding windows (time-windows). |
FlatMapFunction<Row,Row> |
AggregateUtil$.createDataSetSlideWindowPrepareFlatMapFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
TypeInformation<Row> inputType,
boolean isParserCaseSensitive)
Create a
FlatMapFunction that prepares for
non-incremental aggregates of sliding windows (time-windows). |
static RichGroupReduceFunction<Row,Row> |
AggregateUtil.createDataSetSlideWindowPrepareGroupReduceFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
boolean isParserCaseSensitive)
Create a
GroupReduceFunction that prepares for
partial aggregates of sliding windows (time and count-windows). |
RichGroupReduceFunction<Row,Row> |
AggregateUtil$.createDataSetSlideWindowPrepareGroupReduceFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
org.apache.calcite.rel.type.RelDataType physicalInputRowType,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
boolean isParserCaseSensitive)
Create a
GroupReduceFunction that prepares for
partial aggregates of sliding windows (time and count-windows). |
static GroupCombineFunction<Row,Row> |
AggregateUtil.createDataSetWindowAggregationCombineFunction(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,
int[] groupings)
Create a
GroupCombineFunction that pre-aggregation
for aggregates. |
GroupCombineFunction<Row,Row> |
AggregateUtil$.createDataSetWindowAggregationCombineFunction(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,
int[] groupings)
Create a
GroupCombineFunction that pre-aggregation
for 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. |
static MapPartitionFunction<Row,Row> |
AggregateUtil.createDataSetWindowAggregationMapPartitionFunction(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,
int[] groupings)
Create a
MapPartitionFunction that aggregation
for aggregates. |
MapPartitionFunction<Row,Row> |
AggregateUtil$.createDataSetWindowAggregationMapPartitionFunction(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,
int[] groupings)
Create a
MapPartitionFunction that aggregation
for aggregates. |
static MapFunction<Row,Row> |
AggregateUtil.createDataSetWindowPrepareMapFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
boolean isParserCaseSensitive)
Create a
MapFunction that prepares for aggregates. |
MapFunction<Row,Row> |
AggregateUtil$.createDataSetWindowPrepareMapFunction(CodeGenerator generator,
LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
boolean isParserCaseSensitive)
Create a
MapFunction that prepares for aggregates. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.