Hi,
I'm pulling in Timo and Jark as they know Table API better.
Regards,
Roman
On Sun, Apr 11, 2021 at 3:36 PM vtygoss <vtyg...@126.com> wrote:
>
> Hi All,
>
>
> there is a scenario where I need to process OGG Log data in kafka using Flink
> Sql. I can convert the OGG Log Stream to DataStream<RowData> and each event
> has RowKind, but i have trouble converting DataStream<RowData> to a Table.
>
> For test, i tried StreamTableEnvironment#fromDataStream and
> createTemporaryView API, both TableSchema is
>
> ```
>
> root
>
> |-- f0: LEGACY('RAW', 'ANY<org.apache.flink.table.data.RowData>')
>
> ```
>
>
> i want to get the schema :
>
>
> ```
>
> root
>
> |— column1: Type,
>
> |— column2: Type,
>
> ….
>
> ```
>
>
>
> how to convert DataStream<RowData> with RowKind to Table?
>
>
>
> Thank you very much for your reply
>
>
