Thanks Bryan, that worked perfectly.
Nawaz.
From: Bryan Bende [mailto:bbe...@gmail.com]
Sent: Friday, June 17, 2016 1:55 PM
To: users@nifi.apache.org
Subject: Re: RDBMS to Hbase using NIFI
Hi Nawaz,
The PutHBaseJson processor only supports receiving a single json document per
flow file, and th
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
Hi Kumiko,
I would recommend that in your On
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 wrote:
>
...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
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 tends
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
Hi Nawaz,
The PutHBaseJson processor only supports receiving a single json document
per flow file, and the output of ConvertAvroToJson is probably an array of
JSON documents, or maybe multiple JSON documents one after another.
I think the solution would be to stick a SplitJson after ConvertAvroTo
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 trans