About G-Tz

G-Tz · ‎04-12-2021

Hello everyone, I have 2 flow files (tables in CSV format) and I need to merge them into one flow file, but to do that I need to perform a SQL JOIN operation because I only need data that exists in one table but not in the other. Is there a way to do this in NIFI? During the workflow I also convert the format to JSON and perform a SPLIT operation on the data, maybe it’s easier to get the result in need after these conversions. Example for what I need: Csv1: 1,a,NY 2,b,SF 3,w,SP Csv2: 1,a,NY 3,w,SP The result should be: 2,b,SF Thank you!

G-Tz · ‎12-10-2020

thank you very much Mr. Shelton

G-Tz · ‎12-06-2020

Greetings, I work for a large organization that wants to purchase a NIFI system, but before the purchase is made we need to know whether the system is Fault tolerant, in the sense that if a Node / Cluster crashes while consuming / processing / putting the data, it is possible to fully recover the data that was lost, automatically or manually. If the answer is no, is it possible to set NIFI so it won't send Acks to the system from which it consumes the data from, until the moment the data completes the whole flow process and is uploaded to its destination, or at least until the data is uploaded properly to NIFI? thank you!

G-Tz · ‎11-08-2020

Greetings, I have a NIFI flow in which I change a log to a JSON format file and then I need to remove space characters in some of the fields inside the JSON. I use the ReplaceText processor and I need to know how to limit it so that it performs the replacement operation only on specific fields that I define for it. Thank you!!

Online	Offline
Last Visited	‎04-21-2021 08:54 AM

Member Since	‎08-13-2020 02:23 AM
Last Visited	‎04-21-2021 08:54 AM
Posts	4

Cloudera Community

NIFI - Joining 2 flowfiles with SQL JOIN operation

Re: NiFi - Fault tolerance

NiFi - Fault tolerance

Nifi: How can i replace text only in some specific...