Thanks for your help Timo and Fabian,
Got it working with Timo’s suggestion.
On Fri, May 14, 2021 at 6:14 AM Fabian Paul <fabianp...@data-artisans.com>
wrote:
> 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.
>
>
>
