diff options
| author | Xin Ren <iamshrek@126.com> | 2016-05-30 08:40:03 -0500 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-05-30 08:40:03 -0500 |
| commit | 5728aa558e44f056f3e5a7f8726ab174d3830103 (patch) | |
| tree | 28895b5ade8f36ad38801c502386c94a6e950bc6 /core/src | |
| parent | 1360a6d636dd812a27955fc85df8e0255db60dfa (diff) | |
| download | spark-5728aa558e44f056f3e5a7f8726ab174d3830103.tar.gz spark-5728aa558e44f056f3e5a7f8726ab174d3830103.tar.bz2 spark-5728aa558e44f056f3e5a7f8726ab174d3830103.zip | |
[SPARK-15645][STREAMING] Fix some typos of Streaming module
## What changes were proposed in this pull request?
No code change, just some typo fixing.
## How was this patch tested?
Manually run project build with testing, and build is successful.
Author: Xin Ren <iamshrek@126.com>
Closes #13385 from keypointt/codeWalkThroughStreaming.
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/ParallelCollectionRDD.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/rdd/ParallelCollectionRDD.scala b/core/src/main/scala/org/apache/spark/rdd/ParallelCollectionRDD.scala index 34a1c112cb..e9092739b2 100644 --- a/core/src/main/scala/org/apache/spark/rdd/ParallelCollectionRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/ParallelCollectionRDD.scala @@ -32,8 +32,8 @@ import org.apache.spark.util.Utils private[spark] class ParallelCollectionPartition[T: ClassTag]( var rddId: Long, var slice: Int, - var values: Seq[T]) - extends Partition with Serializable { + var values: Seq[T] + ) extends Partition with Serializable { def iterator: Iterator[T] = values.iterator |