You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "radu (JIRA)" <ji...@apache.org> on 2017/05/07 18:42:04 UTC
[jira] [Created] (FLINK-6476) Table environment register row data
stream
radu created FLINK-6476:
---------------------------
Summary: Table environment register row data stream
Key: FLINK-6476
URL: https://issues.apache.org/jira/browse/FLINK-6476
Project: Flink
Issue Type: Improvement
Components: Table API & SQL
Environment: java/scala
Reporter: radu
Assignee: radu
Registering as table source streams with Row is currently not possible:
Java:
DataStream<Row> ds = ...
tableEnv.registerDataStream("MyTableRow", ds, "a, b, c ...");
org.apache.flink.table.api.TableException: Source of type Row(f0: Integer, f1: Long, f2: Integer, f3: String, f4: Integer) cannot be converted into Table.
at org.apache.flink.table.api.TableEnvironment.getFieldInfo(TableEnvironment.scala:680)
at org.apache.flink.table.api.StreamTableEnvironment.registerDataStreamInternal(StreamTableEnvironment.scala:363)
at org.apache.flink.table.api.java.StreamTableEnvironment.registerDataStream(StreamTableEnvironment.scala:133)
at org.apache.flink.table.api.java.stream.sql.SqlITCase.testRow2(SqlITCase.java:92)
Scala:
val ds:DataStream[Row] = ...
tableEnv.registerDataStream("MyTableRow", ds, "a, b, c, d, e");
org.apache.flink.api.java.typeutils.GenericTypeInfo cannot be cast to org.apache.flink.api.common.typeutils.CompositeType
This can be supported by extending the in the org.apache.flink.table.api.TableEnvironment
getFieldInfo()
and by constructing the StreamTableSource correspondingly
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)