I believe Storm will call nextTuple() very often on a spout unless the max_unacked_tuple limit has been reached. You should see calls to that method pretty often, which means you could then just check the current time and (if needed) emit the tuples that will start whatever given cron task you wanted.
On Tue, Oct 7, 2014 at 2:43 AM, 이승진 <[email protected]> wrote: > Dear all, > > > > I know there is a tick tuple component which makes it possible to do > certain job periodically within bolts. > > > > To my knowledge however, it seems like spouts cannot receive a tick tuple > since there's no argument in nextTuple method. > > (BaseRichSpout) > > > > Is there any other option to implement cron-like job within a spout? Any > comment will help. > > Sincerely, > >
