-
Notifications
You must be signed in to change notification settings - Fork 1
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
Groups accumulator for array_agg #233
Conversation
total_num_groups, | ||
|group_index, new_value: ArrayRef| { | ||
let new_value = new_value.as_primitive::<T>(); | ||
self.values[group_index].append( |
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.
You probably want to use extend
here in order to avoid collecting into Vec
.
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.
e.g. self.values[group_index]. extend(new_value.into_iter())
|group_index, new_value: ArrayRef| { | ||
let new_value = new_value.as_string::<i32>(); | ||
|
||
self.values[group_index].append( |
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.
Same here
* Groups accumulator for array_agg * small fix * fmt * clippy * clippy
* Groups accumulator for array_agg * small fix * fmt * clippy * clippy
* Groups accumulator for array_agg * small fix * fmt * clippy * clippy
* Add pool_size method to MemoryPool (#218) (#230) * Add pool_size method to MemoryPool * Fix * Fmt Co-authored-by: Daniël Heres <[email protected]> * Move FileSinkExec::metrics to the correct place (#239) * Groups accumulator for array_agg (#233) * Groups accumulator for array_agg * small fix * fmt * clippy * clippy * Fix clippy * Fix sink output schema being passed in to `FileSinkExec` where input schema was expected * Propagate CSV options (quote, double quote, and escape) through protos * Remove unused field from NthValue * Remove Sized constraint from ExecutionPlan::name --------- Co-authored-by: Daniël Heres <[email protected]> Co-authored-by: Gediminas Aleknavičius <[email protected]> Co-authored-by: svranesevic <[email protected]>
apache#10063