Планирование запуска процессора NiFi при получении первого файла потока за день - PullRequest
0 голосов
/ 30 января 2020

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

Процессор может игнорировать все последующие потоковые файлы.

1 Ответ

0 голосов
/ 30 января 2020

вам необходим любой тип хранилища для запоминания предыдущей даты.

как вариант, используйте DistributedMapCache для хранения предыдущей даты

flow:

----------------------> FetchDistributedMapCache - get prev date
-(success, not found)-> RouteOnAttribute  - compare previous date with current date
-(not matched)--------> PutDistributedMapCache - store new date
----------------------> next processor that triggered on date change
...