diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-10-24 14:29:56 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-10-24 14:31:34 -0700 |
| commit | 9423532fab4d58ac05f283ac2e9baddc3ee48928 (patch) | |
| tree | 0c09663e3c829088e418cf319742e397bbb872a2 /streaming | |
| parent | 05ac9940ee97744b8952ede74edfcd63e6e55a5b (diff) | |
| download | spark-9423532fab4d58ac05f283ac2e9baddc3ee48928.tar.gz spark-9423532fab4d58ac05f283ac2e9baddc3ee48928.tar.bz2 spark-9423532fab4d58ac05f283ac2e9baddc3ee48928.zip | |
Removing Java for now
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala | 7 |
1 files changed, 0 insertions, 7 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala index eae517cff0..459695b7ca 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala @@ -123,13 +123,6 @@ trait JavaDStreamLike[T, This <: JavaDStreamLike[T, This, R], R <: JavaRDDLike[T def glom(): JavaDStream[JList[T]] = new JavaDStream(dstream.glom().map(x => new java.util.ArrayList[T](x.toSeq))) - /** - * Return a new DStream with an increased or decreased level of parallelism. Each RDD in the - * returned DStream has exactly numPartitions partitions. - */ - def repartition(numPartitions: Int): JavaDStream[T] = - new JavaDStream(dstream.repartition(numPartitions)) - /** Return the StreamingContext associated with this DStream */ def context(): StreamingContext = dstream.context() |