spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r...@apache.org
Subject [2/6] git commit: Removing Java for now
Date Fri, 25 Oct 2013 00:08:50 GMT
Removing Java for now


Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/9423532f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/9423532f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/9423532f

Branch: refs/heads/master
Commit: 9423532fab4d58ac05f283ac2e9baddc3ee48928
Parents: 05ac994
Author: Patrick Wendell <pwendell@gmail.com>
Authored: Thu Oct 24 14:29:56 2013 -0700
Committer: Patrick Wendell <pwendell@gmail.com>
Committed: Thu Oct 24 14:31:34 2013 -0700

----------------------------------------------------------------------
 .../org/apache/spark/streaming/api/java/JavaDStreamLike.scala | 7 -------
 1 file changed, 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/9423532f/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala
----------------------------------------------------------------------
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 eae517c..459695b 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()
 


Mime
View raw message