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:

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

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

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.

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