Package | Description |
---|---|
org.apache.flink.table.operations |
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,
ResolvedSchema resolvedSchema) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.