flink globfilepathfilter,如何在包含模式中设置特定的包含文件

mcvgt66p  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(787)
GlobFilePathFilter globFilePathFilter = new GlobFilePathFilter(
            Collections.singletonList("**"),
            Collections.singletonList("**.zip")
    );

无法设置除“**”之外的其他包含模式。
我们只想过滤特定的文件,比如
collections.singletonlist(“**aa.txt”)
你知道吗?

oymdgrw7

oymdgrw71#

Flink1.4不支持这一点,你必须进入文件夹级别才能做到这一点。

相关问题