RE: Custom Controller Service

2016-06-17 Thread Kumiko Yada
Thank you, Mark! It worked as great per your suggestion. Thanks Kumiko From: Mark Payne [mailto:marka...@hotmail.com] Sent: Friday, June 17, 2016 12:26 PM To: users@nifi.apache.org Cc: Ki Kang ; Kevin Verhoeven Subject: Re: Custom Controller Service

Re: Custom Controller Service

2016-06-17 Thread Mark Payne
We could potentially use a Reporting Task for this, actually. Not really the intent of the Reporting Task capability, but it does provide all the necessary lifecycle constructs and is generally easier to implement than Controller Services. -Mark > On Jun 17, 2016, at 3:29 PM, Joe Witt

Re: Custom Controller Service

2016-06-17 Thread Joe Witt
...i wonder if we've done the same ourselves or given similar advice to others. This feels like something the framework should make available as an expected lifecycle point. I could see it making sense for such cases that we would allow 'OnScheduled' to be on controller services and let the user

Re: Custom Controller Service

2016-06-17 Thread Mark Payne
Hi Kumiko, I would recommend that in your OnEnabled method that you just create a ScheduledExecutorService and schedule the task to occur every 24 hours or however you'd like. Then, in your OnDisabled method call shutdown on that ScheduledExecutorService. A word to the wise, though - NiFi

Custom Controller Service

2016-06-17 Thread Kumiko Yada
Hello, I wrote the Custom Controller Service to authenticate the Azure Datalake Store, and I'd like to refresh a token every 24 hours. What is the best way to authenticate every 24 hours? Should I loop the authenticate code every 24 hours in OnEnabled? Thanks Kumiko

RDBMS to Hbase using NIFI

2016-06-17 Thread Nawaz Akther -X (nakther - INSIGHT GLOBAL INC at Cisco)
Hi, I have been trying to transfer data from a relational database(mysql) to hbase using nifi and the processors I am using are the ExecuteSQL which is connected to convertAVROtoJSON which is connected to PutHbaseJson processor. The problem I am facing is that only one record/row is being