flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "radu (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6476) Table environment register row data stream
Date Sun, 07 May 2017 18:42:04 GMT
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:


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)


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


and by constructing the StreamTableSource correspondingly

This message was sent by Atlassian JIRA

View raw message