@Internal public final class AggregateOperationFactory extends Object
AggregateQueryOperation
or WindowAggregateQueryOperation
.Constructor and Description |
---|
AggregateOperationFactory(boolean isStreamingMode) |
Modifier and Type | Method and Description |
---|---|
QueryOperation |
createAggregate(List<ResolvedExpression> groupings,
List<ResolvedExpression> aggregates,
QueryOperation child)
Creates a valid
AggregateQueryOperation operation. |
WindowAggregateQueryOperation.ResolvedGroupWindow |
createResolvedWindow(GroupWindow window,
ExpressionResolver resolver)
Converts an API class to a resolved window for planning with expressions already resolved.
|
QueryOperation |
createWindowAggregate(List<ResolvedExpression> groupings,
List<ResolvedExpression> aggregates,
List<ResolvedExpression> windowProperties,
WindowAggregateQueryOperation.ResolvedGroupWindow window,
QueryOperation child)
Creates a valid
WindowAggregateQueryOperation operation. |
Tuple2<ResolvedExpression,List<String>> |
extractTableAggFunctionAndAliases(Expression callExpr)
Extract a table aggregate Expression and it's aliases.
|
public AggregateOperationFactory(boolean isStreamingMode)
public QueryOperation createAggregate(List<ResolvedExpression> groupings, List<ResolvedExpression> aggregates, QueryOperation child)
AggregateQueryOperation
operation.groupings
- expressions describing grouping key of aggregatesaggregates
- expressions describing aggregation functionschild
- relational operation on top of which to apply the aggregationpublic QueryOperation createWindowAggregate(List<ResolvedExpression> groupings, List<ResolvedExpression> aggregates, List<ResolvedExpression> windowProperties, WindowAggregateQueryOperation.ResolvedGroupWindow window, QueryOperation child)
WindowAggregateQueryOperation
operation.groupings
- expressions describing grouping key of aggregatesaggregates
- expressions describing aggregation functionswindowProperties
- expressions describing window propertieswindow
- grouping window of this aggregationchild
- relational operation on top of which to apply the aggregationpublic WindowAggregateQueryOperation.ResolvedGroupWindow createResolvedWindow(GroupWindow window, ExpressionResolver resolver)
TimeIndicatorTypeInfo
(stream),
SqlTimeTypeInfo
(batch), or BasicTypeInfo.LONG_TYPE_INFO
(batch) typeBasicTypeInfo.LONG_TYPE_INFO
,
or TimeIntervalTypeInfo
typeTimeIntervalTypeInfo
typewindow
- window to resolveresolver
- resolver to resolve potential unresolved field referencespublic Tuple2<ResolvedExpression,List<String>> extractTableAggFunctionAndAliases(Expression callExpr)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.