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

Method tryFlush

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

Source from the content-addressed store, hash-verified

251 void flush() throws InterruptedException;
252
253 boolean tryFlush();
254 }
255
256 public interface Consumer extends MessagePassingQueue.Consumer<Object> {

Callers 2

tryFlushMethod · 0.95
tryFlushRemotesMethod · 0.65

Implementers 3

DirectInserterstorm-client/src/jvm/org/apache/storm/
BatchInserterstorm-client/src/jvm/org/apache/storm/
JCQueuestorm-client/src/jvm/org/apache/storm/

Calls

no outgoing calls

Tested by

no test coverage detected