diff options
| author | Sean Owen <sowen@cloudera.com> | 2016-09-01 12:13:07 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@databricks.com> | 2016-09-01 12:13:07 -0700 |
| commit | 3893e8c576cf1a6decc18701267ce7cd8caaf521 (patch) | |
| tree | e7a7b61f13a348f52ae0a25162157b28203b58ca /docs/streaming-kafka-0-8-integration.md | |
| parent | 2be5f8d7e0819de03971d0af6fa310793d2d0e65 (diff) | |
| download | spark-3893e8c576cf1a6decc18701267ce7cd8caaf521.tar.gz spark-3893e8c576cf1a6decc18701267ce7cd8caaf521.tar.bz2 spark-3893e8c576cf1a6decc18701267ce7cd8caaf521.zip | |
[SPARK-17331][CORE][MLLIB] Avoid allocating 0-length arrays
## What changes were proposed in this pull request?
Avoid allocating some 0-length arrays, esp. in UTF8String, and by using Array.empty in Scala over Array[T]()
## How was this patch tested?
Jenkins
Author: Sean Owen <sowen@cloudera.com>
Closes #14895 from srowen/SPARK-17331.
Diffstat (limited to 'docs/streaming-kafka-0-8-integration.md')
| -rw-r--r-- | docs/streaming-kafka-0-8-integration.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/streaming-kafka-0-8-integration.md b/docs/streaming-kafka-0-8-integration.md index d3fc9adfcf..58b17aa4ce 100644 --- a/docs/streaming-kafka-0-8-integration.md +++ b/docs/streaming-kafka-0-8-integration.md @@ -139,7 +139,7 @@ Next, we discuss how to use this approach in your streaming application. <div class="codetabs"> <div data-lang="scala" markdown="1"> // Hold a reference to the current offset ranges, so it can be used downstream - var offsetRanges = Array[OffsetRange]() + var offsetRanges = Array.empty[OffsetRange] directKafkaStream.transform { rdd => offsetRanges = rdd.asInstanceOf[HasOffsetRanges].offsetRanges |