Member since
08-18-2019
56
Posts
11
Kudos Received
18
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
641 | 11-15-2023 05:38 AM | |
2326 | 07-12-2023 05:38 AM | |
695 | 01-10-2023 01:50 AM | |
983 | 12-06-2022 12:08 AM | |
3813 | 12-02-2022 12:55 AM |
11-20-2020
12:03 AM
my csv is file.csv ok scheme dont need. is possible auto-create table with column names from first line csv?
... View more
11-12-2020
11:21 AM
How many flowfiles you get after splitting? But as example for your properties of your processor If you get like 10 flowfiles set 'minimum number of entries' to 1000 (like maximum) and you have to set the 'minimum bin age' like 10 sec So if the first flowfile comes in with attribute value ABC the flowfile gets hold and the 10 sec timer gets startet and if the next one comes in within the time it is in the same bin. For every bin (in your case 3) the timer gets started for its own. minimum number of entries gets ignored cause you set the minimum bin age
... View more
11-12-2020
10:52 AM
Dont know if it is the best solution, but if you know the keys of the JSON, you can use the Processor 'EvaluateJsonPath' and put the values as attribute to the flowfile. Then use Processor 'AttributsToJson' and set the JSON key and the value with expression language ${attr:trim()}
... View more
09-10-2020
12:54 PM
Maybe I have found a solution.. I'm gonna use the ExecuteSQL to do a "select insert" query.. The query will perform the joins and load the data into a table. Then the QueryDatabaseTable will read from the new table.. That way I'll be able to use the "Max Rows Per Floe File" property.
... View more
07-31-2020
02:25 PM
I am getting similar error. Where are we supposed to add the jar files from the github link provided above. I am able to upload the template, but when I put that in canvas I get this error org.apache.nifi.processors.kite.ConvertJSONToAvro is not known to this NiFi instance
... View more
05-04-2020
06:33 PM
Thanks for your response. But it have only 1 primary key on my table and as i checked, just some id are not deleted @@. Now i use PutSQL instead of PutdatabaseRecord to delete these records, it work well.
... View more
05-04-2020
11:17 AM
Hi, i think your data-format .xlsx is Content of your Flowfile and you don´t have to convert it firtstly? So you can easy add a UpdateAttribute Processor and add the Dynamic-Property "filename" With this Property you overwrite the actually set Filename (you can see there is already an Attribute called "filename" from beginning). As Value you can set the name via Attribute and add the format there e. g. ${filename:append('.xlsx')} or just hard coded like file123.xlsx And after that you add a PutFile or FTP or whatever Processor and send it to the Path you set there.
... View more
04-30-2020
02:07 PM
Thanks for the revert mate. Much Appreciated.
... View more
03-25-2020
02:37 PM
@Faerballert Perhaps you clone your flowfile before the mergeContent processors. So whichever relationship you are connecting to your current mergeContent, you drag a second connection containing that same relationship to a parallel notification flow. Down this parallel flow path you use a replaceText processor to replace the content with the value from the attribute you want to merge. Then you use a mergeContent processor on this path to merge these files using a "," as your delimiter. Then from this mergeContent you do you notification. You may also want to open an Apache Jira with your use case and desired improvement for the existing mergeContent. The more details the better. Hope this helps, Matt
... View more
03-04-2020
09:46 AM
Hi @Faerballert , How can I achieve the same delta changes on cassandra. could u please share some processors which I can use and if I'm using QueryDatabaseTable its asking for jdbc driver and jar details. So please share your thought
... View more
- « Previous
- Next »