Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.internal | |
org.apache.flink.table.operations.utils |
Modifier and Type | Class and Description |
---|---|
class |
SessionWithGapOnTimeWithAlias
Session window on time with alias.
|
class |
SlideWithSizeAndSlideOnTimeWithAlias
Sliding window on time with alias.
|
class |
TumbleWithSizeOnTimeWithAlias
Tumbling window on time with alias.
|
Modifier and Type | Method and Description |
---|---|
GroupWindowedTable |
Table.window(GroupWindow groupWindow)
Groups the records of a table by assigning them to windows defined by a time or row interval.
|
Modifier and Type | Method and Description |
---|---|
GroupWindowedTable |
TableImpl.window(GroupWindow groupWindow) |
Modifier and Type | Method and Description |
---|---|
QueryOperation |
OperationTreeBuilder.windowAggregate(List<Expression> groupingExpressions,
GroupWindow window,
List<Expression> windowProperties,
Expression aggregateFunction,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.windowAggregate(List<Expression> groupingExpressions,
GroupWindow window,
List<Expression> windowProperties,
List<Expression> aggregates,
QueryOperation child) |
QueryOperation |
OperationTreeBuilder.windowTableAggregate(List<Expression> groupingExpressions,
GroupWindow window,
List<Expression> windowProperties,
Expression tableAggFunction,
QueryOperation child) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.