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 /examples/src/main/scala | |
| 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 'examples/src/main/scala')
0 files changed, 0 insertions, 0 deletions