您好,感谢您的回复。 是的,目前是通过connector定义了整张表的字段来获取的数据, connector中是否有字段支持,设置sql语句直接获取数据库检索后返回的数据呢? 现在这种方式,如若数据库表字段变更,以后很难维护啊~
在 2020-12-23 14:36:20,"Wei Zhong" <weizhong0...@gmail.com> 写道: >你好, > >pyflink需要通过声明jdbc connector的方式来从数据库中获取数据。 > >> 在 2020年12月22日,17:40,肖越 <18242988...@163.com> 写道: >> >> 例如:pandas.read_sql()的用法,直接返回源数据,pyflink小白,蹲大佬的答复。 >