提交 feade059 编写于 作者: A Aljoscha Krettek

Add ExecutionEnvironment to ScalaAPICompletessTest

上级 4ddc3f72
......@@ -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",
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册