Added getExecutionEnvironment to the DataSet of the Scala API.

flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala

@@ -88,6 +88,13 @@ class DataSet[T: ClassTag](set: JavaDataSet[T]) {
    */
   def getType: TypeInformation[T] = set.getType
 
+  /**
+   * Returns the execution environment associated with the current DataSet.
+   * @return associated execution environment
+   */
+  def getExecutionEnvironment: ExecutionEnvironment = new ExecutionEnvironment(set
+    .getExecutionEnvironment)
+
   /**
    * Returns the underlying Java DataSet.
    */