From 9423532fab4d58ac05f283ac2e9baddc3ee48928 Mon Sep 17 00:00:00 2001 From: Patrick Wendell Date: Thu, 24 Oct 2013 14:29:56 -0700 Subject: Removing Java for now --- .../org/apache/spark/streaming/api/java/JavaDStreamLike.scala | 7 ------- 1 file changed, 7 deletions(-) (limited to 'streaming') 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() -- cgit v1.2.3