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

Method fail

storm-client/src/jvm/org/apache/storm/utils/BatchHelper.java:39–46  ·  view source on GitHub ↗
(Exception e)

Source from the content-addressed store, hash-verified

37 }
38
39 public void fail(Exception e) {
40 collector.reportError(e);
41 for (Tuple t : tupleBatch) {
42 collector.fail(t);
43 }
44 tupleBatch.clear();
45 forceFlush = false;
46 }
47
48 public void ack() {
49 for (Tuple t : tupleBatch) {

Callers

nothing calls this directly

Calls 3

reportErrorMethod · 0.65
failMethod · 0.65
clearMethod · 0.65

Tested by

no test coverage detected