Re: ListenTcpRecord

2017-10-05 Thread Clay Teahouse
Thanks Bryan, for the feedback. I don't seem to be able to replicate the example in your blog. So, is the flow GenerateFlowFile -> TCPPUT --> LogAttribute and ListenTCPRecord -->LogAttribute? Both TCPPut and ListenTCPRecord are sending data to LogAttribute? Shouldn't ListenTCPRecord be receiv

Nifi:How can i remove “.” from “.filename” in nifi custom processor

2017-10-05 Thread sally
I have send updated file to directory used a logic of putFile but it save file as i ".filenam.xml" and can't get it by getFile Processor how can remove "." from this file, i have read that putFile makes it automatically i mean adding dot in front of flowfile name, but how can i remove this dot? f

Re: ListenTcpRecord

2017-10-05 Thread Bryan Bende
Have you tried using the template? https://gist.githubusercontent.com/bbende/fa2bff34e721fef21453986336664cb2/raw/db658c64f75fec47785ab63920ee23582bf1492f/multi_line_log_processing.xml If you import that it will give you the exact flow from my post and all you have to do is start everything. Put

Re: Nifi:How can i remove “.” from “.filename” in nifi custom processor

2017-10-05 Thread Jeff
Sally, The . in front of the filename is used while the contents of the file are being written, so that the file will not be picked up by processors like ListFile (if configured to watch the same directory to which files are being written) until the writing is complete. Can you confirm that the c

RecordReader and RecordWriter: development work on ruleengine

2017-10-05 Thread Uwe Geercken
Hello, I would like to pick up development on my processor that uses a ruleengine. It is working since several month already but I want to convert the processor to use the new RecordReader/RecordWriter framework. This way I can use any data format, which is really, really cool and will benefit

Re: RecordReader and RecordWriter: development work on ruleengine

2017-10-05 Thread Bryan Bende
Uwe, I don't think there is specific documentation on how to write code using the record readers and writers, but the best example to look at would be ConvertRecord ConvertRecord actually extends from AbstractRecordProcessor: https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-s