(final ByteMap<Long> tsuids)
| 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"; |
nothing calls this directly
no test coverage detected