diff options
| author | Dongjoon Hyun <dongjoon@apache.org> | 2016-03-02 11:48:23 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-03-02 11:48:23 +0000 |
| commit | 366f26d2da0437aab99fd88b70ca12ae18958451 (patch) | |
| tree | 499948d8879bfb8676e9cd63e97954d145d9b97e /examples/src | |
| parent | b4d096ded6540c46a2b07b0b0897cbb0b43ba1e0 (diff) | |
| download | spark-366f26d2da0437aab99fd88b70ca12ae18958451.tar.gz spark-366f26d2da0437aab99fd88b70ca12ae18958451.tar.bz2 spark-366f26d2da0437aab99fd88b70ca12ae18958451.zip | |
[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.
Diffstat (limited to 'examples/src')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/streaming/TwitterAlgebirdHLL.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/TwitterAlgebirdHLL.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/TwitterAlgebirdHLL.scala index 0ec6214fde..6442b2a4e2 100644 --- a/examples/src/main/scala/org/apache/spark/examples/streaming/TwitterAlgebirdHLL.scala +++ b/examples/src/main/scala/org/apache/spark/examples/streaming/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(_ ++ _) |