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

Method flush

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

Source from the content-addressed store, hash-verified

258 void accept(Object event);
259
260 void flush() throws InterruptedException;
261 }
262
263 public interface ExitCondition {

Callers

nothing calls this directly

Implementers 6

TestConsumerstorm-client/test/jvm/org/apache/storm
JCQueueTeststorm-client/test/jvm/org/apache/storm
SingleThreadedConsumerstorm-client/test/jvm/org/apache/storm
Executorstorm-client/src/jvm/org/apache/storm/
WorkerTransferstorm-client/src/jvm/org/apache/storm/
Handlerexamples/storm-perf/src/main/java/org/

Calls

no outgoing calls

Tested by

no test coverage detected