Hi

Creating a new DataSet of type Row, how can I the RowTypeInfo of the row?

For example when I create a new dataset like the following:

Row row = Row.of(1, new Timestamp(1), new Date(1));
System.out.println(env.fromElements(row).getType());

it results in:
Row(f0: Integer, f1: Timestamp, f2: Date)
While Flink automatically use f0, f1, ... for labeling I want to specify
the label name of each element

For example, when I create a new DataSet from a Table, it contains the
Table schema too:

DataSet res = tEnv.toDataSet(table, Row.class);

Row(id: Integer, time: Timestamp, name: String, age: Integer, grade: Double)

So is there any way to create a new DataSet<Row> with optional RowTypeInfo?

Reply via email to