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 /examples | |
| parent | 2be2295ff244eb2585e13346bfc00109443d4287 (diff) | |
| download | spark-b5e60c3253748cf87a76c713ae3388dce1b03107.tar.gz spark-b5e60c3253748cf87a76c713ae3388dce1b03107.tar.bz2 spark-b5e60c3253748cf87a76c713ae3388dce1b03107.zip | |
Corrected order of CountMinSketchMonoid arguments
Diffstat (limited to 'examples')
| -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]() |