Skip to content

[SPARK-27207][SQL] : Ensure aggregate buffers are initialized again for So… #24149

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.

Sign up for GitHub

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

Closed
wants to merge 17 commits into from
Closed

[SPARK-27207][SQL] : Ensure aggregate buffers are initialized again for So… #24149

Changes from all commits
Commits
Show all changes
17 commits
Select commit Hold shift + click to select a range
400db3d
[SPARK-27207] : Ensure aggregate buffers are initialized again for So…
Mar 19, 2019
ea050f7
[SPARK-27207] : Adding Unit Test and addressing reviews
Mar 21, 2019
0714876
[SPARK-27207] : Fixing Scalastyle tests
Mar 21, 2019
b4eaf31
Merge branch 'master' of https://github.com/pgandhi999/spark into SPA…
Mar 25, 2019
4dc1007
[SPARK-27207] : Fix SortBasedAggregator to run with different aggrega…
Mar 29, 2019
088cbc6
[SPARK-27207] : Fix new line for TypedImperativeAggregateSuite
Mar 29, 2019
6a5ed71
[SPARK-27207] : Changing design to use one buffer but initializing fo…
Mar 29, 2019
fb9fea8
Revert "[SPARK-27207] : Changing design to use one buffer but initial…
Apr 1, 2019
433b1bb
[SPARK-27207] : Revert to previous commit and serialize the buffer wi…
Apr 5, 2019
446e182
[SPARK-27207] : Upmerging with master branch
Apr 9, 2019
8f5c6b0
[SPARK-27207] : Reverting the two buffer logic and simplifying the code
Apr 30, 2019
db46cf7
Merge branch 'master' of https://github.com/pgandhi999/spark into SPA…
Apr 30, 2019
df330fa
[SPARK-27207] : Coming up with a unit test for custom UDAF
May 6, 2019
5bd474c
[SPARK-27207] : Fixing Scalastyle Tests
May 6, 2019
006616e
[SPARK-27207] : Simplifying unit test and indentation
May 7, 2019
c8959f4
[SPARK-27207] : Reverting changes and updating doc
May 8, 2019
28ea0f9
Merge branch 'master' of https://github.com/pgandhi999/spark into SPA…
May 8, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion ...alyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,7 @@ case class AggregateExpression(
* ([[aggBufferAttributes]]) of an aggregation buffer which is used to hold partial aggregate
* results. At runtime, multiple aggregate functions are evaluated by the same operator using a
* combined aggregation buffer which concatenates the aggregation buffers of the individual
* aggregate functions.
* aggregate functions. Please note that aggregate functions should be stateless.
*
* Code which accepts [[AggregateFunction]] instances should be prepared to handle both types of
* aggregate functions.
Expand Down