Ashutosh Joshi
03/23/2023, 10:38 AMpublic class SelectAllFields extends TableFunction<Row> {
public void eval(Row row) {
collect(row);
}
}
2 - register it -
env.createTemporarySystemFunction("SelectAllFields", SelectAllFields.class);
3 - using through sql -
select name, SelectAllFields(*) as meta from table1