You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2014/11/19 15:19:15 UTC
incubator-flink git commit: Added getExecutionEnvironment to the
DataSet of the Scala API.
Repository: incubator-flink
Updated Branches:
refs/heads/master da6063045 -> 54aa41b3f
Added getExecutionEnvironment to the DataSet of the Scala API.
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/54aa41b3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/54aa41b3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/54aa41b3
Branch: refs/heads/master
Commit: 54aa41b3f1709b3065944267b0b71d45e6c55f56
Parents: da60630
Author: Till Rohrmann <tr...@apache.org>
Authored: Wed Nov 19 15:06:32 2014 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Wed Nov 19 15:10:12 2014 +0100
----------------------------------------------------------------------
.../src/main/scala/org/apache/flink/api/scala/DataSet.scala | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/54aa41b3/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
----------------------------------------------------------------------
diff --git a/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala b/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
index d1233e6..783d976 100644
--- a/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
+++ b/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
@@ -89,6 +89,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.
*/
private[flink] def javaSet: JavaDataSet[T] = set