Я опрашиваю папку, в которой есть несколько CSV-файлов, через задание Flink.
После прочтения файла задание flink будет обрабатывать его строка за строкой.
Одно из моих требований - построить логику, которая будет выполнять обработку на основе имени файла.
Например:
Если имя файла содержит «ABC», тогда должна вызываться логика 1
Или, если имя файла содержит «DEF», то логика 2 должна называться
Есть ли какой-нибудь способ, которым я могу получить имя файла в работе Flink.