Method call

src/meta/TSUIDQuery.java:175–200

(final byte[] incoming_tsuid)

    
    class TSUIDCB implements Callback<Deferred<IncomingDataPoint>, byte[]> {
      @Override
      public Deferred<IncomingDataPoint> call(final byte[] incoming_tsuid) 
          throws Exception {
        if (tsuid == null && incoming_tsuid == null) {
          return Deferred.fromError(new RuntimeException("Both incoming and "
              + "supplied TSUIDs were null for " + TSUIDQuery.this));
        } else if (incoming_tsuid != null) {
          setTSUID(incoming_tsuid);
        }
        if (back_scan < 1 && meta_enabled) {
          final GetRequest get = new GetRequest(tsdb.metaTable(), tsuid);
          get.family(TSMeta.FAMILY());
          get.qualifier(TSMeta.COUNTER_QUALIFIER());
          return tsdb.getClient().get(get).addCallbackDeferring(new MetaCB());
        }
        
        if (last_timestamp > 0) {
          last_timestamp = Internal.baseTime(last_timestamp);
        } else {
          last_timestamp = Internal.baseTime(DateTime.currentTimeMillis());
        }
        final byte[] key = RowKey.rowKeyFromTSUID(tsdb, tsuid, last_timestamp);
        final GetRequest get = new GetRequest(tsdb.dataTable(), key);
        get.family(TSDB.FAMILY());
        return tsdb.getClient().get(get).addCallbackDeferring(new LastPointCB());
      }
      @Override
      public String toString() {
        return "TSUID callback";