Re: pyflink1.12 进行多表关联后的结果类型是TableResult,如何转为Table类型

2020-12-22 文章 Wei Zhong
你好,

使用env.sql_update()执行select语句可以获得Table类型的结果。

> 在 2020年12月22日,13:25,肖越 <18242988...@163.com> 写道:
> 
> 通过sql进行左连接查询,sql语句为:
> sql = ''' Insert into print_sink select a.id, a.pf_id, b.symbol_id from  a \
> left join b on b.day_id = a.biz_date where a.ccy_type = 'AC' and \
> a.pf_id = '1030100122' and b.symbol_id = '2030004042' and a.biz_date 
> between '20160701' and '20170307' '''
> 
> 
> table_result = env.execute_sql(sql)
> 通过env.execute_sql()执行后的结果是 TableResult , 如何转成Table类型?
> 或者有哪些其他的方式,可以直接执行表的连接操作,返回结果是Table类型?
> 



pyflink1.12 进行多表关联后的结果类型是TableResult,如何转为Table类型

2020-12-21 文章 肖越
通过sql进行左连接查询,sql语句为:
sql = ''' Insert into print_sink select a.id, a.pf_id, b.symbol_id from  a \
 left join b on b.day_id = a.biz_date where a.ccy_type = 'AC' and \
 a.pf_id = '1030100122' and b.symbol_id = '2030004042' and a.biz_date 
between '20160701' and '20170307' '''


table_result = env.execute_sql(sql)
通过env.execute_sql()执行后的结果是 TableResult , 如何转成Table类型?
或者有哪些其他的方式,可以直接执行表的连接操作,返回结果是Table类型?