Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Corrected order of CountMinSketchMonoid arguments

  • Loading branch information...
commit b5e60c3253748cf87a76c713ae3388dce1b03107 1 parent 2be2295
Erik van oosten erikvanoosten authored
2  examples/src/main/scala/spark/streaming/examples/TwitterAlgebirdCMS.scala
View
@@ -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]()
Please sign in to comment.
Something went wrong with that request. Please try again.