Repository: spark Updated Branches: refs/heads/branch-1.5 3ee2c8d16 -> 39493b235
Fixed AtmoicReference<> Example Author: Mahmoud Lababidi <labab...@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 <r...@databricks.com> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/39493b23 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/39493b23 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/39493b23 Branch: refs/heads/branch-1.5 Commit: 39493b235ddaa2123e14629935712c43e4a88c87 Parents: 3ee2c8d Author: Mahmoud Lababidi <labab...@gmail.com> Authored: Mon Aug 10 13:02:01 2015 -0700 Committer: Reynold Xin <r...@databricks.com> Committed: Mon Aug 10 13:02:12 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/39493b23/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: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
