You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2014/09/22 14:29:21 UTC
[39/60] git commit: Add ExecutionEnvironment to ScalaAPICompletessTest
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 <al...@gmail.com>
Authored: Thu Sep 18 18:00:16 2014 +0200
Committer: Aljoscha Krettek <al...@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",