Hi si_tianqiang,
自定义 UDF 可以解决你的问题吗？ 比如 接收 kakfa 的数据字段定义成 hbaseQuery，然后自定义 UDF 去根据 query 查询数据。 Best， Hailong Wang 在 2020-11-06 10:41:53，"site" <[email protected]> 写道： >看了官网的示例，发现sql中传入的值都是固定的，我有一个场景是从kafka消息队列接收查询条件，然后通过flink-sql映射hbase表进行查询并写入结果表。我使用了将消息队列映射表再join数据表的方式，回想一下这种方式很不妥，有什么好的方法实现sql入参的动态查询呢？
