How to create schema for Flink table

[Soheil Pourbafrani]

I want to do some transformation on raw data and then create a table from that. Is it possible to create a schema for the table (in advance) and then using that transformed dataset and schema create the table?

[Hequn Cheng]

Hi Soheil,

DataSet can be converted to or from a Table. More details here: https://ci.apache.org/projects/flink/flink-docs-master/dev/table/common.html#convert-a-datastream-or-dataset-into-a-table

Let me know if you have any questions.

Best, Hequn

On Sun, Jan 27, 2019 at 5:37 AM Soheil Pourbafrani <[hidden email]> wrote:

I want to do some transformation on raw data and then create a table from that. Is it possible to create a schema for the table (in advance) and then using that transformed dataset and schema create the table?