Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3277#discussion_r100297140
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRel.scala
---
@@ -19,27 +19,20 @@
package org.apache.flink.table.plan.nodes.datastream
import org.apache.calcite.rel.RelNode
-import org.apache.flink.api.common.typeinfo.TypeInformation
-import org.apache.flink.table.plan.nodes.FlinkRel
import org.apache.flink.streaming.api.datastream.DataStream
import org.apache.flink.table.api.StreamTableEnvironment
+import org.apache.flink.table.plan.nodes.FlinkRel
+import org.apache.flink.types.Row
trait DataStreamRel extends RelNode with FlinkRel {
/**
* Translates the FlinkRelNode into a Flink operator.
*
* @param tableEnv The [[StreamTableEnvironment]] 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.
* @return DataStream of type expectedType or RowTypeInfo
--- End diff --
DataStream of Row
---
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.
---
