-
Notifications
You must be signed in to change notification settings - Fork 1.3k
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
Remove Accumulator::update
and Accumulator::merge
#1582
Conversation
a5c1c70
to
2e2da40
Compare
Nice @jimexist -- you beat me to it :) There are a few more instances that need updating -- will see if I can try and help fix it |
2e2da40
to
2835eb2
Compare
cdb36a9
to
603fe41
Compare
603fe41
to
f9f6fe1
Compare
88797ea
to
0f39d02
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.
Nice work @jimexist
} | ||
|
||
impl Accumulator for ArrayAggAccumulator { | ||
fn update_batch(&mut self, values: &[ArrayRef]) -> Result<()> { |
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.
I think it would be a good idea as a follow on PR to update these implementations to avoid the use of ScalarValue.
I'll try find some time this week to do it (I need some coding time :) -- lots of reviewing so far)
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.
let's track this in a GitHub issue
0f39d02
to
80d5969
Compare
Thanks @jimexist -- this is a great piece of work |
Accumulator::update
and Accumulator::merge
Which issue does this PR close?
Closes #1549
Rationale for this change
What changes are included in this PR?
Are there any user-facing changes?