https://github.com/apache/incubator-storm/blob/master/storm-core/src/jvm/backtype/storm/hooks/BaseTaskHook.java
Override this guy, apply the task hook in either your Storm Conf or in the bolt its self. List<String> listOfHooks = Lists.newArrayList(MyTaskHook.class.getName()); stormConfig.put(Config.TOPOLOGY_AUTO_TASK_HOOKS, listOfHooks); OR In prepare(), topologyContext.addTaskTook() Michael Rose (@Xorlev <https://twitter.com/xorlev>) Senior Platform Engineer, FullContact <http://www.fullcontact.com/> [email protected] On Wed, Mar 5, 2014 at 1:12 PM, Brian O'Neill <[email protected]> wrote: > > Sorry, we may have missed something obvious, but is there a way to count > ack'd tuples? We are looking for a hook that would give us access to tuple > that has been fully processed. > > I'm guessing we could override the Spout implementation, but that seems a > bit messy. > > We could make it the last thing in the topology, but if tuples were > filtered along the way, we wouldn't see them. > > Has anyone done something similar? > > -brian > > -- > Brian ONeill > CTO, Health Market Science (http://healthmarketscience.com) > mobile:215.588.6024 > blog: http://brianoneill.blogspot.com/ > twitter: @boneill42 >
