[streaming] [scala] Revert removing getJavaStream() from DataStream

wtanaka · Feb 4, 2016 · 116337f · 116337f
1 parent 69f7f6d
commit 116337f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
@@ -44,7 +44,7 @@ class DataStream[T](stream: JavaStream[T]) {
   /**
    * Gets the underlying java DataStream object.
    */
-  private[flink] def javaStream: JavaStream[T] = stream
+  def javaStream: JavaStream[T] = stream
 
   /**
     * Returns the [[StreamExecutionEnvironment]] associated with the current [[DataStream]].
@@ -130,7 +130,7 @@ class DataStream[T](stream: JavaStream[T]) {
     case _ => throw new UnsupportedOperationException("Only supported for operators.")
     this
   }
-  
+
   /**
    * Turns off chaining for this operator so thread co-location will not be
    * used as an optimization. </p> Chaining can be turned off for the whole