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

问题描述 投票:0回答:1
 GlobFilePathFilter globFilePathFilter = new GlobFilePathFilter(
            Collections.singletonList("**"),
            Collections.singletonList("**.zip")
    );

除了“**”之外,无法设置其他包含的模式。

我们只想过滤特定的文件,比如

Collections.singletonList( “** aa.txt文件”)

任何的想法?

filesystems apache-flink filefilter
1个回答
0
投票

Flink 1.4不支持此功能,您必须执行文件夹级别才能执行此操作。

© www.soinside.com 2019 - 2024. All rights reserved.