С процессорами ExecuteSQL / ExecuteSQLRecord вы можете указать «Размер выходного пакета», что приведет к созданию нескольких потоковых файлов. Каждый файл потока содержит executesql.row.count.
Теперь, как проще всего рассчитать sum(executesql.row.count) для одной таблицы?
Можно сделать AttributesToJSON (drop content) => MergeContent (defragment) => QueryRecord (counting) => EvaluateJSONPath (back to attribute). Все-таки это слишком сложно ИМХО. В идеале я хотел бы как-нибудь добавить атрибуты, после MergeContent. Проблема в том, что MergeContent удаляет атрибуты с одним и тем же ключом, но с разными значениями. Также у Nifi нет процессора для добавления динамики c количество атрибутов.