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 id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
NamedWindowProperty[] namedWindowProperties,
List<InputProperty> inputProperties,
RowType localAggInputRowType,
RowType outputType,
String description) |
StreamExecGlobalWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
NamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType localAggInputRowType,
RowType outputType,
String description) |
StreamExecLocalWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLocalWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
NamedWindowProperty[] namedWindowProperties,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
NamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowDeduplicate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] partitionKeys,
int orderKey,
boolean keepLastRow,
WindowingStrategy windowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowDeduplicate(ReadableConfig tableConfig,
int[] partitionKeys,
int orderKey,
boolean keepLastRow,
WindowingStrategy windowing,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
JoinSpec joinSpec,
WindowingStrategy leftWindowing,
WindowingStrategy rightWindowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowJoin(ReadableConfig tableConfig,
JoinSpec joinSpec,
WindowingStrategy leftWindowing,
WindowingStrategy rightWindowing,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecWindowRank(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
boolean outputRankNumber,
WindowingStrategy windowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowRank(ReadableConfig tableConfig,
RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
boolean outputRankNumber,
WindowingStrategy windowing,
InputProperty inputProperty,
RowType outputType,
String description) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.