Repository: spark Updated Branches: refs/heads/master 00b655cce -> d28521275
Fixed AtmoicReference<> Example Author: Mahmoud Lababidi <[email protected]> Closes #8076 from lababidi/master and squashes the following commits: af4553b [Mahmoud Lababidi] Fixed AtmoicReference<> Example Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/d2852127 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/d2852127 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/d2852127 Branch: refs/heads/master Commit: d285212756168200383bf4df2c951bd80a492a7c Parents: 00b655c Author: Mahmoud Lababidi <[email protected]> Authored: Mon Aug 10 13:02:01 2015 -0700 Committer: Reynold Xin <[email protected]> Committed: Mon Aug 10 13:02:01 2015 -0700 ---------------------------------------------------------------------- docs/streaming-kafka-integration.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/d2852127/docs/streaming-kafka-integration.md ---------------------------------------------------------------------- diff --git a/docs/streaming-kafka-integration.md b/docs/streaming-kafka-integration.md index 775d508..7571e22 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>>() { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
