У меня есть требование, что мне нужно обрабатывать плоские файлы в NiFi, а затем загружать их в Hive.для этого я использую ListSFTP -> FetchSFTP -> PutHDFS процессоры и работает хорошо.
Теперь мне нужно выполнить проверку данных из плоского файла в Hive, это означает, что мне нужно сравнить количество записей в файле с количеством записей втаблица кустов.
для плоского файла, QueryRecord процессор работает нормально для подсчета, но мне нужно получить имя плоского файла, количество записей плоских файлов, текущую метку времени, имя таблицы кустов, записи таблицы кустов.
Подскажите, пожалуйста, какой процессор подходит для этого?