Also I don't see a way to a fail batch programmatically like you can do with traditional storm? What happens if I throw a Failed Exception from a within function, state query or persist?
On Sun, Mar 2, 2014 at 9:27 AM, David Smith <davidksmit...@gmail.com> wrote: > I'm trying to implement ITridentSpout but I'm having a hard time figure > out where acking for a batch happens. What's the difference between: > > - ITridentSpout.BatchCoordinator.success > - ITridentSpout.Emitter.success > > What will be called when the whole batch is completed by trident topology? > > Thanks, > David >
