Package | Description |
---|---|
org.apache.flink.table.planner.plan.logical | |
org.apache.flink.table.planner.plan.nodes.exec.stream | |
org.apache.flink.table.planner.plan.trait |
Modifier and Type | Class and Description |
---|---|
class |
CumulativeWindowSpec
Logical representation of a cumulative window specification.
|
class |
HoppingWindowSpec
Logical representation of a hopping window specification.
|
class |
TumblingWindowSpec
Logical representation of a tumbling window specification.
|
Modifier and Type | Field and Description |
---|---|
protected WindowSpec |
WindowingStrategy.window |
Modifier and Type | Method and Description |
---|---|
WindowSpec |
WindowingStrategy.getWindow() |
Constructor and Description |
---|
SliceAttachedWindowingStrategy(WindowSpec window,
LogicalType timeAttributeType,
int sliceEnd) |
TimeAttributeWindowingStrategy(WindowSpec window,
LogicalType timeAttributeType,
int timeAttributeIndex) |
WindowAttachedWindowingStrategy(WindowSpec window,
LogicalType timeAttributeType,
int windowEnd)
Creates a
WindowAttachedWindowingStrategy which only WindowAttachedWindowingStrategy.windowEnd is attatched. |
WindowAttachedWindowingStrategy(WindowSpec window,
LogicalType timeAttributeType,
int windowStart,
int windowEnd) |
WindowingStrategy(WindowSpec window,
LogicalType timeAttributeType) |
WindowingStrategy(WindowSpec window,
LogicalType timeAttributeType,
boolean isRowtime) |
Modifier and Type | Method and Description |
---|---|
protected SliceAssigner |
StreamExecWindowAggregateBase.createSliceAssigner(WindowSpec windowSpec,
int timeAttributeIndex,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Method and Description |
---|---|
WindowSpec |
RelWindowProperties.getWindowSpec() |
Modifier and Type | Method and Description |
---|---|
static RelWindowProperties |
RelWindowProperties.create(org.apache.calcite.util.ImmutableBitSet windowStartColumns,
org.apache.calcite.util.ImmutableBitSet windowEndColumns,
org.apache.calcite.util.ImmutableBitSet windowTimeColumns,
WindowSpec windowSpec,
LogicalType timeAttributeType)
Creates a
RelWindowProperties , may return null if the window properties can't be
propagated (loss window start and window end columns). |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.