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:01 -0700 |
| commit | d285212756168200383bf4df2c951bd80a492a7c (patch) | |
| tree | 62da6e5bb6da9abb57ae45f143b540d3cbb1438b /docs/streaming-kafka-integration.md | |
| parent | 00b655cced637e1c3b750c19266086b9dcd7c158 (diff) | |
| download | spark-d285212756168200383bf4df2c951bd80a492a7c.tar.gz spark-d285212756168200383bf4df2c951bd80a492a7c.tar.bz2 spark-d285212756168200383bf4df2c951bd80a492a7c.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
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>>() { |