Я использую textFileStream для обработки файлов, поступающих в каталог.Можно ли извлечь имя файла, который вызвал обработку?
Например, когда файл 2019-04-18_very_important.txt попадает в каталог, который я слушаю, я хотел бы иметь возможность извлечь имя этого файла.
context
.textFileStream("/path/to/directory")
.transform(rdd -> /** How can I get '2019-04-18_very_important.txt' here? **/)
...