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

Method tryFlush

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

if(batchSz>1) : Non-Blocking call. Tries to flush as many as it can. Returns true if flushed at least 1. if(batchSz==1) : This is a NO-OP. Returns true immediately.

()

Source from the content-addressed store, hash-verified

238 * NO-OP. Returns true immediately.
239 */
240 public boolean tryFlush() {
241 Inserter inserter = getInserter();
242 return inserter.tryFlush();
243 }
244
245 private interface Inserter {
246 // blocking call that can be interrupted using Thread.interrupt()

Callers

nothing calls this directly

Calls 2

getInserterMethod · 0.95
tryFlushMethod · 0.95

Tested by

no test coverage detected