Я хотел бы удалить файл после того, как все строки в файле обработаны. Мои потоки выглядят какУдалите файл после обработки всех строк в файле
source (file --fixedDelay=0 --outputType=text/plain --dir=XXX) |
splitter --expression=payload.split('\\n') |
transform -> filter -> sink
Мои файлы хранятся в каталоге, который наблюдает модуль файла. Я хотел бы, чтобы каждый файл был удален после его обработки.
Спасибо.