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.