flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guillermo Ortiz <konstt2...@gmail.com>
Subject Re: Flume and PollableSource.
Date Tue, 17 Sep 2013 10:37:51 GMT
Thank you!,

I have another question, I have checked and take a look to the code, how
could I reimplement the code?? Because, It looks like I can't change the
values of each recalled independent when it got result or not. could it
that possible?


2013/9/16 Hari Shreedharan <hshreedharan@cloudera.com>

>  You don't need to do anything with the PollableSourceRunner. Once you
> create your PollableSource, drop it into Flume's classpath and configure it
> as required and associate it with an active channel. Once that is done,
> Flume will create a PollableSourceRunner instance to run your
> PollableSource, and run it (it will sit in a loop and call your class's
> process method).
> Thanks,
> Hari
> On Monday, September 16, 2013 at 7:40 AM, Guillermo Ortiz wrote:
> Hello,
> I'm working with Flume and I have a doubt, I want to create a PollSource
> and go to look for the data time to time.
> I have create a class which implement PollableSource:
> *public class PullHttps extends AbstractSource implements PollableSource,*
> *        Configurable {*
> *
> *
> But, I don't know how I should create the loop,,, who is who calls my
> Source?? I have been reading the documentation and I have found the class
> *PollableSourceRunner * but, I don't know if I should use that class and
> I haven't gotten to advanced on that way.
> How do I have to use a PollableSource??
> Thank you.

View raw message