diff options
author | Ankur Dave <ankurdave@gmail.com> | 2011-04-23 13:38:37 -0700 |
---|---|---|
committer | Ankur Dave <ankurdave@gmail.com> | 2011-05-03 15:40:45 -0700 |
commit | 563c5e717cc75869c328bba17116313eab9e976b (patch) | |
tree | 99c2894a1bc9d4317b11d7de26c98f514b879794 /project | |
parent | c18fa3ebc6848d2da19ac2f68c9e22870e135ecd (diff) | |
download | spark-563c5e717cc75869c328bba17116313eab9e976b.tar.gz spark-563c5e717cc75869c328bba17116313eab9e976b.tar.bz2 spark-563c5e717cc75869c328bba17116313eab9e976b.zip |
Refactor and add aggregator support
Refactored out the agg() and comp() methods from Pregel.run.
Defined an implicit conversion to allow applications that don't use
aggregators to avoid including a null argument for the result of the
aggregator in the compute function.
Diffstat (limited to 'project')
0 files changed, 0 insertions, 0 deletions