Как читать несколько файлов с определенным типом имени из одного каталога в Flink - PullRequest
0 голосов
/ 07 июня 2019

Я читаю из нескольких файлов, которые находятся в одной папке с именами, такими как 1_W, 2_W, 3_W, 1_R, 2_R, 3_R, но теперь я хочу читать только файлы, которые заканчиваются на «_W», а не «_R»

в моем коде я использую параметр рекурсивного перечисления, который читает все файлы в каталоге

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
BatchTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(env);
Configuration parameters = new Configuration();
parameters.setBoolean("recursive.file.enumeration", true);
DataSet<String> message = env.readTextFile("/home/gaurav").withParameters(parameters);

если я даю путь как / home / gaurav / * _ W это дает мне ошибку файла, а не fount

...