Skip to content
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

Add covar, covar_pop and covar_samp aggregate functions #1551

Merged
merged 13 commits into from
Jan 13, 2022
Merged

Add covar, covar_pop and covar_samp aggregate functions #1551

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
35f9e10
initial change
realno Jan 11, 2022
c522167
fix some logic
realno Jan 11, 2022
081e896
adding basic tests
realno Jan 11, 2022
ab0886b
mark update and merge unimplemented
realno Jan 11, 2022
4a9c0bb
Merge branch 'master' into add-covar-operators
realno Jan 11, 2022
ed31b9b
all tests pass
realno Jan 11, 2022
f1ff993
add doc and tests
realno Jan 11, 2022
bbb1244
lint
realno Jan 12, 2022
d5188b1
clipy
realno Jan 12, 2022
4498faf
add more merge tests
realno Jan 12, 2022
e9e40d0
add merge tests for stddev
realno Jan 12, 2022
524eb8c
lint
realno Jan 13, 2022
1b7810e
clippy
realno Jan 13, 2022
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
Prev Previous commit
Next Next commit
clipy
  • Loading branch information
@realno
realno committed Jan 12, 2022
commit d5188b158f9e1e61ef947490c6f3940a208f799e
2 changes: 1 addition & 1 deletion datafusion/src/physical_plan/expressions/covariance.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -672,7 +672,7 @@ mod tests {
.state()?
.iter()
.map(|v| vec![v.clone()])
.map(|x| ScalarValue::iter_to_array(x.clone()).map(|e| e).unwrap())
.map(|x| ScalarValue::iter_to_array(x).unwrap())
.collect::<Vec<_>>();
accum1.merge_batch(&state2)?;
accum1.evaluate()
Expand Down