how to convert DataStream to Table

[vtygoss]

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