flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [39/60] git commit: Add ExecutionEnvironment to ScalaAPICompletessTest
Date Mon, 22 Sep 2014 12:29:21 GMT
Add ExecutionEnvironment to ScalaAPICompletessTest


Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/feade059
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/feade059
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/feade059

Branch: refs/heads/master
Commit: feade0592f4351b39f1cb02d8ae36d5364e2acd4
Parents: 4ddc3f7
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Thu Sep 18 18:00:16 2014 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Mon Sep 22 09:59:59 2014 +0200

----------------------------------------------------------------------
 .../org/apache/flink/api/scala/ScalaAPICompletenessTest.scala  | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/feade059/flink-scala/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
----------------------------------------------------------------------
diff --git a/flink-scala/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
b/flink-scala/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
index 5c4606f..97939f0 100644
--- a/flink-scala/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
+++ b/flink-scala/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
@@ -54,6 +54,8 @@ class ScalaAPICompletenessTest {
       "org.apache.flink.api.java.operators.TwoInputOperator.getInput2",
       "org.apache.flink.api.java.operators.TwoInputOperator.getInput1Type",
       "org.apache.flink.api.java.operators.TwoInputOperator.getInput2Type",
+      "org.apache.flink.api.java.ExecutionEnvironment.localExecutionIsAllowed",
+      "org.apache.flink.api.java.ExecutionEnvironment.setDefaultLocalParallelism",
 
       // This is really just a mapper, which in Scala can easily expressed as a map lambda
       "org.apache.flink.api.java.DataSet.writeAsFormattedText",
@@ -138,6 +140,10 @@ class ScalaAPICompletenessTest {
   def testCompleteness(): Unit = {
     checkMethods("DataSet", "DataSet", classOf[JavaDataSet[_]], classOf[DataSet[_]])
 
+    checkMethods(
+      "ExecutionEnvironment", "ExecutionEnvironment",
+      classOf[org.apache.flink.api.java.ExecutionEnvironment], classOf[ExecutionEnvironment])
+
     checkMethods("Operator", "DataSet", classOf[Operator[_, _]], classOf[DataSet[_]])
 
     checkMethods("UnsortedGrouping", "GroupedDataSet",


Mime
View raw message