Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3277#discussion_r100296701
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetRel.scala
---
@@ -19,26 +19,19 @@
package org.apache.flink.table.plan.nodes.dataset
import org.apache.calcite.rel.RelNode
+import org.apache.flink.api.java.DataSet
import org.apache.flink.table.api.BatchTableEnvironment
import org.apache.flink.table.plan.nodes.FlinkRel
-import org.apache.flink.api.common.typeinfo.TypeInformation
-import org.apache.flink.api.java.DataSet
+import org.apache.flink.types.Row
trait DataSetRel extends RelNode with FlinkRel {
/**
* Translates the [[DataSetRel]] node into a [[DataSet]] operator.
*
- * @param tableEnv [[BatchTableEnvironment]] of the translated
Table.
- * @param expectedType specifies the type the Flink operator should
return. The type must
- * have the same arity as the result. For instance,
if the
- * expected type is a RowTypeInfo this method will
return a DataSet of
- * type Row. If the expected type is Tuple2, the
operator will return
- * a Tuple2 if possible. Row otherwise.
+ * @param tableEnv The [[BatchTableEnvironment]] of the translated
Table.
* @return DataSet of type expectedType or RowTypeInfo
--- End diff --
DataSet of Row is enough
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
