你好,
使用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_i
通过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_
