You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/05/09 16:58:05 UTC
[jira] [Closed] (FLINK-6476) Table environment register row data
stream
[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fabian Hueske closed FLINK-6476.
--------------------------------
Resolution: Implemented
Fix Version/s: 1.4.0
1.3.0
Implemented for 1.3 with 28a89d1cac79063245bbc1ad9d262e3bc94b17b9
Implemented for 1.4 with 6cd98a9b6f223bc665831e4ff3626c98aed9b272
> 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
> Labels: feature, patch
> Fix For: 1.3.0, 1.4.0
>
>
> 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)