diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-04-02 19:24:12 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-04-02 19:24:12 -0700 |
| commit | dfe98ca798d84e6847330012f1332d9271156534 (patch) | |
| tree | c01e72de1c2372b55337d40452c7cefa7e4dc828 | |
| parent | b5d78307ca79b6c8c0f2733750e546ea5b0b0bb1 (diff) | |
| parent | b5e60c3253748cf87a76c713ae3388dce1b03107 (diff) | |
| download | spark-dfe98ca798d84e6847330012f1332d9271156534.tar.gz spark-dfe98ca798d84e6847330012f1332d9271156534.tar.bz2 spark-dfe98ca798d84e6847330012f1332d9271156534.zip | |
Merge pull request #550 from erikvanoosten/master
corrected Algebird example
| -rw-r--r-- | examples/src/main/scala/spark/streaming/examples/TwitterAlgebirdCMS.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/scala/spark/streaming/examples/TwitterAlgebirdCMS.scala b/examples/src/main/scala/spark/streaming/examples/TwitterAlgebirdCMS.scala index 483aae452b..a9642100e3 100644 --- a/examples/src/main/scala/spark/streaming/examples/TwitterAlgebirdCMS.scala +++ b/examples/src/main/scala/spark/streaming/examples/TwitterAlgebirdCMS.scala @@ -49,7 +49,7 @@ object TwitterAlgebirdCMS { val users = stream.map(status => status.getUser.getId) - val cms = new CountMinSketchMonoid(DELTA, EPS, SEED, PERC) + val cms = new CountMinSketchMonoid(EPS, DELTA, SEED, PERC) var globalCMS = cms.zero val mm = new MapMonoid[Long, Int]() var globalExact = Map[Long, Int]() |