Added waitForStop and stop to JavaStreamingContext.

streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala

@@ -432,7 +432,7 @@ class StreamingContext private[streaming] (
 
   /**
    * Wait for the execution to stop. Any exceptions that occurs during the execution
-   * will be thrown here.
+   * will be thrown in this thread.
    */
   def waitForStop() {
     waiter.waitForStopOrError()
@@ -440,7 +440,7 @@ class StreamingContext private[streaming] (
 
   /**
    * Wait for the execution to stop. Any exceptions that occurs during the execution
-   * will be thrown here.
+   * will be thrown in this thread.
    * @param timeout time to wait
    */
   def waitForStop(timeout: Long) {
@@ -449,6 +449,7 @@ class StreamingContext private[streaming] (
 
   /**
    * Stop the execution of the streams.
+   * @param stopSparkContext Stop the associated SparkContext or not
    */
   def stop(stopSparkContext: Boolean = true) = synchronized {
     scheduler.stop()

streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala

@@ -483,9 +483,28 @@ class JavaStreamingContext(val ssc: StreamingContext) {
   def start() = ssc.start()
 
   /**
-   * Stop the execution of the streams.
+   * Wait for the execution to stop. Any exceptions that occurs during the execution
+   * will be thrown in this thread.
+   */
+  def waitForStop() = ssc.waitForStop()
+
+  /**
+   * Wait for the execution to stop. Any exceptions that occurs during the execution
+   * will be thrown in this thread.
+   * @param timeout time to wait
+   */
+  def waitForStop(timeout: Long) = ssc.waitForStop(timeout)
+
+  /**
+   * Stop the execution of the streams. Will stop the associated JavaSparkContext as well.
    */
   def stop() = ssc.stop()
+
+  /**
+   * Stop the execution of the streams.
+   * @param stopSparkContext Stop the associated SparkContext or not
+   */
+  def stop(stopSparkContext: Boolean) = ssc.stop(stopSparkContext)
 }
 
 /**