[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 <dongj...@apache.org> Closes #11451 from dongjoon-hyun/replace_deprecated_hll_apply. Project: http://git-wip-us.apache.org/repos/asf/bahir/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/8ad5dddf Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/8ad5dddf Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/8ad5dddf Branch: refs/heads/master Commit: 8ad5dddfc9465d02d8cdb184e2c4fd10084f4e19 Parents: 6ac5a18 Author: Dongjoon Hyun <dongj...@apache.org> Authored: Wed Mar 2 11:48:23 2016 +0000 Committer: Sean Owen <so...@cloudera.com> Committed: Wed Mar 2 11:48:23 2016 +0000 ---------------------------------------------------------------------- .../spark/examples/streaming/twitter/TwitterAlgebirdHLL.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir/blob/8ad5dddf/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterAlgebirdHLL.scala ---------------------------------------------------------------------- diff --git a/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterAlgebirdHLL.scala b/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterAlgebirdHLL.scala index 0ec6214..6442b2a 100644 --- a/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterAlgebirdHLL.scala +++ b/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterAlgebirdHLL.scala @@ -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(_ ++ _)