| 653 | private class MetaCB implements Callback<Deferred<IncomingDataPoint>, |
| 654 | ArrayList<KeyValue>> { |
| 655 | @Override |
| 656 | public Deferred<IncomingDataPoint> call(final ArrayList<KeyValue> row) |
| 657 | throws Exception { |
| 658 | if (row == null) { |
| 659 | return Deferred.fromResult(null); |
| 660 | } |
| 661 | last_timestamp = Internal.baseTime(row.get(0).timestamp()); |
| 662 | final byte[] key = RowKey.rowKeyFromTSUID(tsdb, tsuid, last_timestamp); |
| 663 | final GetRequest get = new GetRequest(tsdb.dataTable(), key); |
| 664 | get.family(TSDB.FAMILY()); |
| 665 | return tsdb.getClient().get(get).addCallbackDeferring(new LastPointCB()); |
| 666 | } |
| 667 | @Override |
| 668 | public String toString() { |
| 669 | return "Meta TSCounter lookup"; |