Package | Description |
---|---|
org.apache.flink.table.operations | |
org.apache.flink.table.operations.utils.factories |
Modifier and Type | Method and Description |
---|---|
WindowAggregateQueryOperation.ResolvedGroupWindow |
WindowAggregateQueryOperation.getGroupWindow() |
static WindowAggregateQueryOperation.ResolvedGroupWindow |
WindowAggregateQueryOperation.ResolvedGroupWindow.sessionWindow(String alias,
FieldReferenceExpression timeAttribute,
ValueLiteralExpression gap) |
static WindowAggregateQueryOperation.ResolvedGroupWindow |
WindowAggregateQueryOperation.ResolvedGroupWindow.slidingWindow(String alias,
FieldReferenceExpression timeAttribute,
ValueLiteralExpression size,
ValueLiteralExpression slide) |
static WindowAggregateQueryOperation.ResolvedGroupWindow |
WindowAggregateQueryOperation.ResolvedGroupWindow.tumblingWindow(String alias,
FieldReferenceExpression timeAttribute,
ValueLiteralExpression size) |
Constructor and Description |
---|
WindowAggregateQueryOperation(List<ResolvedExpression> groupingExpressions,
List<ResolvedExpression> aggregateExpressions,
List<ResolvedExpression> windowPropertiesExpressions,
WindowAggregateQueryOperation.ResolvedGroupWindow groupWindow,
QueryOperation child,
TableSchema tableSchema) |
Modifier and Type | Method and Description |
---|---|
WindowAggregateQueryOperation.ResolvedGroupWindow |
AggregateOperationFactory.createResolvedWindow(GroupWindow window,
ExpressionResolver resolver)
Converts an API class to a resolved window for planning with expressions already resolved.
|
Modifier and Type | Method and Description |
---|---|
QueryOperation |
AggregateOperationFactory.createWindowAggregate(List<ResolvedExpression> groupings,
List<ResolvedExpression> aggregates,
List<ResolvedExpression> windowProperties,
WindowAggregateQueryOperation.ResolvedGroupWindow window,
QueryOperation child)
Creates a valid
WindowAggregateQueryOperation operation. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.