Skip to content

Commit

Permalink
use double for count multiply
Browse files Browse the repository at this point in the history
  • Loading branch information
liujiayi771 committed Mar 6, 2024
1 parent f431dd3 commit f04d109
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions velox/functions/lib/aggregates/CentralMomentsAggregatesBase.h
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ struct CentralMomentsAccumulator {
m1_ += deltaN;
m2_ += dm2;
m3_ += dm2 * deltaN * (count() - 2) - 3 * deltaN * oldM2;
m4_ += dm2 * deltaN2 * (count() * (double)count() - 3 * count() + 3) +
m4_ += dm2 * deltaN2 * (1.0 * count() * count() - 3.0 * count() + 3) +
6 * deltaN2 * oldM2 - 4 * deltaN * oldM3;
}

Expand Down Expand Up @@ -107,16 +107,16 @@ struct CentralMomentsAccumulator {
m2_ += otherM2 + delta2 * oldCount * otherCount / count();
m3_ += otherM3 +
delta3 * oldCount * otherCount * (oldCount - otherCount) /
(count() * count()) +
(1.0 * count() * count()) +
3 * delta * (oldCount * otherM2 - otherCount * oldM2) / count();
m4_ += otherM4 +
delta4 * oldCount * otherCount *
(oldCount * oldCount - oldCount * otherCount +
otherCount * otherCount) /
(count() * count() * count()) +
(1.0 * count() * count() * count()) +
6 * delta2 *
(oldCount * oldCount * otherM2 + otherCount * otherCount * oldM2) /
(count() * count()) +
(1.0 * count() * count()) +
4 * delta * (oldCount * otherM3 - otherCount * oldM3) / count();
}

Expand Down

0 comments on commit f04d109

Please sign in to comment.