search

tylerchr / parallel-database

An experimental parallelized database optimized for read performance
2 stars 0 forks source link

Implement accumulator materialization #5

Open tylerchr opened 8 years ago

tylerchr commented 8 years ago

After we have reduced all the distributed accumulators together (see !4) we still need a way to "materialize" an accumulator into its final value.

For example, an AverageAccumulator looks like the following and we want to come up with 0.379796833.

&main.AverageAccumulator{Col:"artist_hotttnesss", sum:379796.8328380485, ct:1000000}