是 source 类,不是JDBCSinkFunction 。我理解UDTF 应该是用来 做数据transformation的,能做到动态的去查询吗?


> 在 2019年7月4日,下午4:14,qi luo <[email protected]> 写道:
> 
> LookupableTableSource

回复