-
Notifications
You must be signed in to change notification settings - Fork 3.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Aggregation and window refactor #9837
Conversation
3e3ce8e
to
604a361
Compare
Does this require benchmarks to be run? |
604a361
to
245f90c
Compare
It would be great if you could do that. It shouldn't affect anything, but you never know. |
What APIs are changed by this PR? |
There are no SPI changes. There are quite a few changes to the internal function APIs, especially around aggregations and window functions |
5a4b94b
to
5d91db2
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good through commit "Change AggregationFunctionMetadata to have multiple intermediate types"
Typo "AggergationMetadata" in commit title |
Typo "aggergation" in commit titles |
Looks good through commit "Add deterministic to ResolvedFunction" |
5d91db2
to
08c5d13
Compare
...rino-main/src/main/java/io/trino/operator/aggregation/AbstractMinMaxAggregationFunction.java
Outdated
Show resolved
Hide resolved
.../trino-main/src/main/java/io/trino/operator/aggregation/GenericAccumulatorFactoryBinder.java
Outdated
Show resolved
Hide resolved
.../trino-main/src/main/java/io/trino/operator/aggregation/GenericAccumulatorFactoryBinder.java
Outdated
Show resolved
Hide resolved
core/trino-spi/src/main/java/io/trino/spi/function/AccumulatorStateFactory.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/test/java/io/trino/operator/TestAnnotationEngineForAggregates.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/operator/window/pattern/ProjectingPagesWindowIndex.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/test/java/io/trino/operator/aggregation/TestingAggregationFunction.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/operator/aggregation/CompiledAccumulatorFactory.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/operator/window/RegularWindowPartition.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/operator/aggregation/AccumulatorCompiler.java
Outdated
Show resolved
Hide resolved
Remove unnecessary methods from AccumulatorFactory Simplify aggregation binding by using layering Assume argument ordering in accumulator compiler Add AggregatorFactory to simplify usage in operators
Combine method is only allowed for decomposable aggregations
08c5d13
to
9aa40b2
Compare
No description provided.