diff options
| author | Mahmoud Lababidi <lababidi@gmail.com> | 2015-08-10 13:02:01 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-08-10 13:02:12 -0700 |
| commit | 39493b235ddaa2123e14629935712c43e4a88c87 (patch) | |
| tree | 3740fb2832d3f7909edd9a9bfa9e0dd43fb24e79 /docs/streaming-kafka-integration.md | |
| parent | 3ee2c8d169e48e0bca3fab702466e7a855f57f8e (diff) | |
| download | spark-39493b235ddaa2123e14629935712c43e4a88c87.tar.gz spark-39493b235ddaa2123e14629935712c43e4a88c87.tar.bz2 spark-39493b235ddaa2123e14629935712c43e4a88c87.zip | |
Fixed AtmoicReference<> Example
Author: Mahmoud Lababidi <lababidi@gmail.com>
Closes #8076 from lababidi/master and squashes the following commits:
af4553b [Mahmoud Lababidi] Fixed AtmoicReference<> Example
(cherry picked from commit d285212756168200383bf4df2c951bd80a492a7c)
Signed-off-by: Reynold Xin <rxin@databricks.com>
Diffstat (limited to 'docs/streaming-kafka-integration.md')
| -rw-r--r-- | docs/streaming-kafka-integration.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/streaming-kafka-integration.md b/docs/streaming-kafka-integration.md index 775d508d48..7571e22575 100644 --- a/docs/streaming-kafka-integration.md +++ b/docs/streaming-kafka-integration.md @@ -152,7 +152,7 @@ Next, we discuss how to use this approach in your streaming application. </div> <div data-lang="java" markdown="1"> // Hold a reference to the current offset ranges, so it can be used downstream - final AtomicReference<OffsetRange[]> offsetRanges = new AtomicReference(); + final AtomicReference<OffsetRange[]> offsetRanges = new AtomicReference<>(); directKafkaStream.transformToPair( new Function<JavaPairRDD<String, String>, JavaPairRDD<String, String>>() { |