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

Method size

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

Source from the content-addressed store, hash-verified

93 }
94
95 public int size() {
96 return recvQueue.size() + overflowQ.size();
97 }
98
99 public double getQueueLoad() {
100 return ((double) recvQueue.size()) / recvQueue.capacity();

Callers 1

testBasicBackPressureMethod · 0.95

Calls 1

sizeMethod · 0.65

Tested by 1

testBasicBackPressureMethod · 0.76