Flink GlobFilePathFilter, как установить конкретный включенный файл во включенном шаблоне - PullRequest
0 голосов
/ 27 сентября 2018
 GlobFilePathFilter globFilePathFilter = new GlobFilePathFilter(
            Collections.singletonList("**"),
            Collections.singletonList("**.zip")
    );

Невозможно установить другой включенный шаблон, кроме "**".

Мы хотим фильтровать только определенные файлы, например

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

Есть идеи?

1 Ответ

0 голосов
/ 27 марта 2019

Flink 1.4 не поддерживает это, вам нужно перейти на уровень папок, чтобы сделать это.

...