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]() |