Как я могу отправить атрибут записи процессора NiFi на следующий процессор?

Question

Я использую процессор GetHDFSEvents, чтобы узнать hdfs.inotify.event.path. Мне нужно получить уведомление о пути при создании нового файла в формате hdf. Как передать атрибут hdfs.inotify.event.path следующему процессору для выполнения сценария оболочки на основе пути

Answer 1

Используйте ListHDFS и атрибут пути вместо GetHDFS, если вы просто хотите получать уведомления.

Answer 2

Попробуйте использовать процессор ListHDFS и используйте командный процессор Fetchhdfs или ExecuteStream. Использовать язык выражений $ {path} / $ {filename}