diff options
author | Erik van oosten <e.vanoosten@grons.nl> | 2013-04-02 15:25:22 +0300 |
---|---|---|
committer | Erik van oosten <e.vanoosten@grons.nl> | 2013-04-02 15:25:22 +0300 |
commit | b5e60c3253748cf87a76c713ae3388dce1b03107 (patch) | |
tree | 4e5b30d52a258b9c2fe5e71e354e9c9121917d57 | |
parent | 2be2295ff244eb2585e13346bfc00109443d4287 (diff) | |
download | spark-b5e60c3253748cf87a76c713ae3388dce1b03107.tar.gz spark-b5e60c3253748cf87a76c713ae3388dce1b03107.tar.bz2 spark-b5e60c3253748cf87a76c713ae3388dce1b03107.zip |
Corrected order of CountMinSketchMonoid arguments
-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]() |