有没有办法把flink Row类转换为Object

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

有没有办法把flink Row类转换为Object

ZT.Ren
基于flink做二次开发中,需要将flink SQL执行结果打印到会话中,会话中执行结果打印流程固定打印List<Object>类型数据。
大部分查询引擎(比如presto)都会在ResultSet中提供getObject方法,flink中如何实现?
Reply | Threaded
Open this post in threaded view
|

Re: 有没有办法把flink Row类转换为Object

Jark
Administrator
你要的是这个功能么? 1.11 上已经支持了。

CloseableIterator<Row> result = Table#execute#collect()

On Wed, 11 Nov 2020 at 15:23, ZT.Ren <[hidden email]> wrote:

> 基于flink做二次开发中,需要将flink SQL执行结果打印到会话中,会话中执行结果打印流程固定打印List<Object>类型数据。
> 大部分查询引擎(比如presto)都会在ResultSet中提供getObject方法,flink中如何实现?