MCPcopy Create free account
hub / github.com/apache/storm / ack

Method ack

storm-client/src/jvm/org/apache/storm/utils/BatchHelper.java:48–54  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

46 }
47
48 public void ack() {
49 for (Tuple t : tupleBatch) {
50 collector.ack(t);
51 }
52 tupleBatch.clear();
53 forceFlush = false;
54 }
55
56 public boolean shouldHandle(Tuple tuple) {
57 if (TupleUtils.isTick(tuple)) {

Callers

nothing calls this directly

Calls 2

ackMethod · 0.65
clearMethod · 0.65

Tested by

no test coverage detected