Permalink
Browse files

fix unit test

  • Loading branch information...
aaron-siegel committed Dec 13, 2012
1 parent b38466d commit ede346d66e6dd5876362e7d4e83743d245e205ce
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/main/scala/com/twitter/scalding/ReduceOperations.scala
@@ -95,12 +95,12 @@ trait ReduceOperations[+Self <: ReduceOperations[Self]] extends java.io.Serializ
*/
def approxUniques(f : (Fields, Fields), errPercent : Double = 1.0) = {
hyperLogLogMap(f, errPercent) { (monoid,hll) => monoid.estimateSize(hll) }
- { _.toString.getBytes("UTF-8") }
+ { x: Any => x.toString.getBytes("UTF-8") }
}
def hyperLogLog(f : (Fields, Fields), errPercent : Double = 1.0) = {
hyperLogLogMap(f, errPercent) { (_,hll) => hll }
- { _.toString.getBytes("UTF-8") }
+ { x: Any => x.toString.getBytes("UTF-8") }
}
def hyperLogLogMap[T,U](f : (Fields, Fields), errPercent : Double = 1.0)

0 comments on commit ede346d

Please sign in to comment.