MCPcopy Index your code
hub / github.com/OpenTSDB/opentsdb / call

Method call

src/tsd/QueryRpc.java:423–435  ·  view source on GitHub ↗
(final ByteMap<Long> tsuids)

Source from the content-addressed store, hash-verified

421 */
422 final class TSUIDQueryCB implements Callback<Deferred<Object>, ByteMap<Long>> {
423 public Deferred<Object> call(final ByteMap<Long> tsuids) throws Exception {
424 if (tsuids == null || tsuids.isEmpty()) {
425 return null;
426 }
427 final ArrayList<Deferred<IncomingDataPoint>> deferreds =
428 new ArrayList<Deferred<IncomingDataPoint>>(tsuids.size());
429 for (Map.Entry<byte[], Long> entry : tsuids.entrySet()) {
430 deferreds.add(TSUIDQuery.getLastPoint(tsdb, entry.getKey(),
431 data_query.getResolveNames(), data_query.getBackScan(),
432 entry.getValue()));
433 }
434 return Deferred.group(deferreds).addCallbackDeferring(new FetchCB());
435 }
436 @Override
437 public String toString() {
438 return "TSMeta scan CB";

Callers

nothing calls this directly

Calls 9

getLastPointMethod · 0.95
isEmptyMethod · 0.80
getResolveNamesMethod · 0.80
getBackScanMethod · 0.80
sizeMethod · 0.65
addMethod · 0.45
getKeyMethod · 0.45
getValueMethod · 0.45
groupMethod · 0.45

Tested by

no test coverage detected