question Re: Nifi to insert the flow one after another in Archives of Support Questions (Read Only)

Nifi to insert the flow one after another

raaj_muthu — Tue, 18 Sep 2018 12:54:02 GMT

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

Re: Nifi to insert the flow one after another

Shu_ashu — Tue, 18 Sep 2018 19:54:45 GMT

@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.

Re: Nifi to insert the flow one after another

raaj_muthu — Wed, 19 Sep 2018 02:40:32 GMT

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

Re: Nifi to insert the flow one after another

Shu_ashu — Wed, 19 Sep 2018 04:09:20 GMT

@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.