Hi,   I have a nifi flow which has 1000's of flow files. Each of the flow file has an impala/hive statement and each of them have different execution times. How do i use control rate processor to trigger next flow file only if the previous flow file has been processed (success/failure of the flow file doesn't matter)? ... View more

Hi,   Is there any processor to add some text/characters to each line in the flowfile in Nifi. Replace text seems to be more complicated given that the partiton value keeps changing.   compute incremental stats mydb.mytable partition (date=2023-07-21); compute incremental stats mydb.mytable partition (name=abc); to compute incremental stats mydb.mytable partition (date='2023-07-21'); compute incremental stats mydb.mytable partition (name='abc');   Note: date=2023-07-21 comes as a complete string from the sys.partitions.part_name table in hive. We will need to add '' to the date. ... View more