Package | Description |
---|---|
org.apache.flink.table.planner.plan.logical | |
org.apache.flink.table.planner.plan.nodes.exec.stream |
Modifier and Type | Class and Description |
---|---|
class |
SliceAttachedWindowingStrategy
A windowing strategy that gets windows from input columns as window slice have been assigned and
attached to the physical columns.
|
class |
TimeAttributeWindowingStrategy
A windowing strategy that gets windows by calculating on time attribute column.
|
class |
WindowAttachedWindowingStrategy
A windowing strategy that gets windows from input columns as windows have been assigned and
attached to the physical columns.
|
Modifier and Type | Method and Description |
---|---|
protected SliceAssigner |
StreamExecWindowAggregateBase.createSliceAssigner(WindowingStrategy windowingStrategy,
java.time.ZoneId shiftTimeZone) |
Constructor and Description |
---|
StreamExecGlobalWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
PlannerNamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType localAggInputRowType,
RowType outputType,
String description) |
StreamExecGlobalWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
PlannerNamedWindowProperty[] namedWindowProperties,
int id,
List<InputProperty> inputProperties,
RowType localAggInputRowType,
RowType outputType,
String description) |
StreamExecLocalWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecLocalWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
PlannerNamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
PlannerNamedWindowProperty[] namedWindowProperties,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowJoin(JoinSpec joinSpec,
WindowingStrategy leftWindowing,
WindowingStrategy rightWindowing,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecWindowJoin(JoinSpec joinSpec,
WindowingStrategy leftWindowing,
WindowingStrategy rightWindowing,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowRank(RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
boolean outputRankNumber,
WindowingStrategy windowing,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowRank(RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
boolean outputRankNumber,
WindowingStrategy windowing,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.