removed wasted print in DStream

YanTangZhai · Sep 20, 2014 · 10b5b04 · 10b5b04
1 parent e54f986
commit 10b5b04
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 26 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
@@ -54,15 +54,6 @@ trait JavaDStreamLike[T, This <: JavaDStreamLike[T, This, R], R <: JavaRDDLike[T
     dstream.print()
   }
 
-  def print(label: String = null): Unit = {
-    dstream.print(label)
-  }
-
-  def outputToFile(): Unit = {
-    dstream.outputToFile()
-  }
-
-
   /**
    * Return a new DStream in which each RDD has a single element generated by counting each RDD
    * of this DStream.

diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala
@@ -617,23 +617,6 @@ abstract class DStream[T: ClassTag] (
     new ForEachDStream(this, context.sparkContext.clean(foreachFunc)).register()
   }
 
-
-  def print(label: String = null) {
-    def foreachFunc = (rdd: RDD[T], time: Time) => {
-      val first11 = rdd.take(11)
-      println ("-------------------------------------------")
-      println ("Time: " + time)
-      println ("-------------------------------------------")
-      if(label != null){
-        println (label)
-      }
-      first11.take(10).foreach(println)
-      if (first11.size > 10) println("...")
-      println()
-    }
-    new ForEachDStream(this, context.sparkContext.clean(foreachFunc)).register()
-  }
-
   /**
    * Return a new DStream in which each RDD contains all the elements in seen in a
    * sliding window of time over this DStream. The new DStream generates RDDs with