I need to create checksums in my ETL process. Therefore I need to sum up a numeric column in my JDBC-connected table(s). Copying the data works fine so far, but I was not able to find the correct NiFi processor for this aggregation task.
How can I calculate the sum of a table column? Which processor to use (is there something similar for the SelectHiveQL processor, which works fine for the same aggregation task)? And how to compare these two results (from two different tables) to check if the sums are equal?
I already tried to use a ExecuteSQL processor but there I get an SchemaParseException: