Hi John,
Can you maybe share more code about how you build the DataStrean<Row>?
It would also be good to know against which Flink version you are testing. I
just
tried the following code against the current master and:
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);
DataStream<Row> rowStream = env.fromElements(Row.of(1, "test1"), Row.of(2,
"test2"));
Table t = tableEnv.fromDataStream(rowStream);
t.execute().print();
seems to work fine.
+----+-------------+--------------------------------+
| op | f0 | f1 |
+----+-------------+--------------------------------+
| +I | 1 | test1 |
| +I | 2 | test2 |
+----+-------------+--------------------------------+
Best,
Fabian
> On 14. May 2021, at 09:01, John Smith <hojjat.test.em...@gmail.com> wrote:
>
> Hi,
>
> Sorry if this is a duplicate question but I couldn't find any answer to my
> question.
> I am trying to convert a DataStream<Row> into a Table where the columns in
> the Row objects in the DataStream<Row> will become columns of the Table.
> Here is how I tried to do it:
>
> //Creating a DataStream of Row type. Let's assume the Row type has 3 columns:
> // (c1 BIGINT, c2 String, c3 String)
> DataStream<Row> rowStream = ....
>
> // Convert it to a Table
> Table t = tableEnv.fromDataStream(rowStream)
>
> // Print the table
> t.execute().print();
>
> However, when I print the table it has one column of type Row instead of
> three columns (c1, c2, c3).
>
> What I see in the print result is:
>
> +----+--------------------------------+
> | op | f0 |
> +----+--------------------------------+
> | +I | +I{c1=1620968140951, ... |
>
> What I would like to see is:
>
> +----+-------------------------------------------+
> | op | c1 | c2 | c3 |
> +----+-------------------------------------------+
> | +I | 1620968140951 | 'foo' | 'bar' |
>
> How can I convert the DataStream to a table that has the same columns as the
> columns in Row in the DataStream.
> Would really appreciate it if anyone can share a code snippet for the above
> example.
>
> Thanks,
> JS.
>
