【问题标题】:Flink GlobFilePathFilter, how to set the specific included file in the included patternFlink GlobFilePathFilter,如何在包含模式中设置具体的包含文件
【发布时间】:2019-03-03 16:47:27
【问题描述】:
 GlobFilePathFilter globFilePathFilter = new GlobFilePathFilter(
            Collections.singletonList("**"),
            Collections.singletonList("**.zip")
    );

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

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

Collections.singletonList("**AA.txt")

有什么想法吗?

【问题讨论】:

    标签: filesystems apache-flink filefilter


    【解决方案1】:

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

    【讨论】:

      猜你喜欢
      • 2011-02-21
      • 1970-01-01
      • 2020-12-04
      • 1970-01-01
      • 2017-06-20
      • 2016-12-05
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多