Hi, 可以为 HBaseDynamicTableSource 实现 FilterPushDown[1] 接口。这样子 你直接添加的 filter 会被下推到 Source，从而在读取的时候过滤掉不相关的数据。
[1] https://github.com/apache/flink/blob/a09cc4704433cb76b936a51b422d812e1ae57945/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsFilterPushDown.java#L63 Best, Shengkai 汪赟 <wang455581...@icloud.com.invalid> 于2022年4月14日周四 09:30写道： > flink table > 查询hbase表时，如何添加过滤器，类似prefixFiler，而不是直接使用算子filter，因为会扫描全表在进行过滤，十分不友好 > flink streaming 读取时，是可以添加过滤器，但是返回数据是流式的，转化为表也是陆续增加，而我本身是想拿到所需数据然后进行统计。 > 请问下如何做到table在查询原表时能用上条件，而不是全量扫描进行过滤？ > > >
