[MINOR][STREAMING] Replace deprecated apply
with create
in example.
## What changes were proposed in this pull request? Twitter Algebird deprecated `apply` in HyperLogLog.scala. ``` deprecated("Use toHLL", since = "0.10.0 / 2015-05") def apply[T <% Array[Byte]](t: T) = create(t) ``` This PR replace the deprecated usage `apply` with new `create` according to the upstream change. ## How was this patch tested? manual. ``` /bin/spark-submit --class org.apache.spark.examples.streaming.TwitterAlgebirdHLL examples/target/scala-2.11/spark-examples-2.0.0-SNAPSHOT-hadoop2.2.0.jar ``` Author: Dongjoon Hyun <dongjoon@apache.org> Closes #11451 from dongjoon-hyun/replace_deprecated_hll_apply.
This commit is contained in:
parent
b4d096ded6
commit
366f26d2da
|
@ -62,7 +62,7 @@ object TwitterAlgebirdHLL {
|
|||
var userSet: Set[Long] = Set()
|
||||
|
||||
val approxUsers = users.mapPartitions(ids => {
|
||||
ids.map(id => hll(id))
|
||||
ids.map(id => hll.create(id))
|
||||
}).reduce(_ + _)
|
||||
|
||||
val exactUsers = users.map(id => Set(id)).reduce(_ ++ _)
|
||||
|
|
Loading…
Reference in a new issue