Nifi to insert the flow one after another

[#1]

Hello everybody,

I'm using Routetext processor to separate JSON records to different flow.Ultimately I need Flow1 should be inserted into HBASE table first , Flow 2 should be executed second and so on.How I can achieve this.

Basically Inserts should insert data to HBase first,Updates should happen next and Delete should happen last .

Attached the Sample test.xml

[#2 · Accepted solution]

@Raj ji

For this use case you have to use Wait-Notify processors to finish inserting records first then Update the records and last for deleting the records.

Refer to this and this articles for configuring and usage of Wait/Notify processors.

[#3]

@Shu Is it possible to add two RowIdentifier/RowIdentifier Field name in PutHbaseJson , Like ServerName,ServerNo or ${ServerName},${ServerNo} .

[#4]

@Raj ji

Yes you can use it..
PutHBaseJson processor:-

1. expects json individual messages(not an array)
2. You need to extract the values for ServerName,ServerNo from the content using EvaluateJsonPath processor then use
Row Identifier

${ServerName},${ServerNo}

(or)

PutHBaseRecord processor:

Using Record processor we don't need to split the array of json messages if you are using this processor but we need to prepare the row_id by using Update Record processor by using concat(/ServerName,',',/ServerNo) function.

Refer to this link for more details regards to UpdateRecord processor concat function usage.