About jricogar

jricogar · ‎10-18-2018

Hello, How can I verify that the sftp file has finished copying? because listSFTP processor is listenning, but some files do not complete because they have many megabytes and the fetchsftp processor captures it before the transfer ends. Thanks

jricogar · ‎10-16-2018

@Shu The problem now is when i try use this processor, the fileflow incrase up to 10,000 fileflows but in the folder there is only 46 files, i don't know if it is a problem or no. How should I configure after the FetchHDFS processor? Thank you

jricogar · ‎10-15-2018

I don't know how use this command in GetHDFSFileInfo processor and after the fetchHDFS processor. Sorry

jricogar · ‎10-15-2018

I just want to create a groovy script that counts the fileflows and if there is less than 9 run a script shell. Thanks

jricogar · ‎10-15-2018

Hello, i need use fetchHDF processor in the middle of the flow. I use first updateAttribute before fetchHDFS to create variable path and filename, but my problem is that i need to take all the files in a folder and i don't know how do it. updateattribute.jpg

jricogar · ‎10-10-2018

Hi, I need create groovy script to count th fileflows, this is my script: def trigger = session.get() def flowFiles = session.get() if(flowFiles.size() < 9) { session.transfer(flowFiles,REL_SUCCESS) }else { session.transfer(flowFiles, REL_FAILURE) } I want launch a script if de fileflow files are < 9. But the error is:

jricogar · ‎10-02-2018

@Shu I would need to look in an HDFS folder and check that before 10 a.m. there are 5 files, if there are not 5 files I should run PutSNS processor. If there are 0 files, How can I check that? because in this case no fileflow would be sent Thanks!

jricogar · ‎10-01-2018

Hello, I need create warnings and alerts. I will recive "a.txt" and "b.txt" files in a input folder, it's possible create a warning if the files are not received before 10 o'clock and create a alert if are not received before 12 o'clock? thanks!!

jricogar · ‎10-01-2018

Thanks @Shu , It has been very helpful!!

jricogar · ‎09-28-2018

Hello, I need link 3 column in all rows of the file, for example: column1;column2;column3;2018;09;27 column1_1;column2_1;column3_1;2018;09;27 column1_2;column2_2;column3_2;2018;09;27 the output file must contains only 4 columns: column1;column2;column3;20180927 column1_1;column2_1;column3_1;20180927 column1_2;column2_2;column3_2;20180927 The input file is .txt and the output file should be .txt Thaks!!

Online	Offline
Last Visited	‎10-23-2018 03:05 PM

Member Since	‎09-20-2018 09:48 AM
Last Visited	‎10-23-2018 03:05 PM
Posts	17

Cloudera Community

NiFi - check if the file in sftp is complete

Re: NiFi - fetchHDFS without ListHDFS

Re: NiFi - fetchHDFS without ListHDFS

Re: NiFi - Script count fileFlows Groovy

NiFi - fetchHDFS without ListHDFS

NiFi - Script count fileFlows Groovy

Re: NIFI - Create alerts

NIFI - Create alerts

Re: NIFI - link 3 columns

NIFI - link 3 columns