flink sql数组选择到java数组Map器

gt0wga4j  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(479)

有没有办法把sql行Map器Map到java数组对象
例子:

tableEnvironment.toRetractStream(table, Row.class)

    select ARRAY[ Event(e1.id, e1.name, e1.businessDate),
  Event(e2.id, e2.name, e2.businessDate)
  from EventMessages e1 join EventMessages e2
  on e1.name = e2.name
  and e.name ='ABC'

tableenvironment.toretractstream(table,row.class)-->row.class工作正常,但必须逐个字段手动将其转换为对象。
我需要创建什么样的对象来传递它来代替行,以便它可以直接转换为那个对象?
谢谢你的帮助。谢谢

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题