Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
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
ack
Method · 0.65
clear
Method · 0.65
Tested by
no test coverage detected