Rozważmy poniższej tabeli:
hbase(main):009:0> create 't1', { NAME => 'f1', VERSIONS => 100 }
hbase(main):010:0> put 't1', 'key1', 'f1:a', 'value1'
hbase(main):011:0> put 't1', 'key1', 'f1:a', 'value2'
hbase(main):012:0> put 't1', 'key1', 'f1:a', 'value3'
hbase(main):013:0> put 't1', 'key2', 'f1:a', 'value4'
hbase(main):014:0> put 't1', 'key2', 'f1:a', 'value5'
hbase(main):015:0> put 't1', 'key1', 'f1:a', 'value6'
Oto jego skan w skorupkach ze wszystkimi wersjami:
hbase(main):003:0> scan 't1', {VERSIONS => 100 }
ROW COLUMN+CELL
key1 column=f1:a, timestamp=1416083314098, value=value6
key1 column=f1:a, timestamp=1416083294981, value=value3
key1 column=f1:a, timestamp=1416083293273, value=value2
key1 column=f1:a, timestamp=1416083291009, value=value1
key2 column=f1:a, timestamp=1416083305050, value=value5
key2 column=f1:a, timestamp=1416083299840, value=value4
Oto skan ograniczone do określonego znacznika czasu, jak prosiłeś:
hbase(main):002:0> scan 't1', { TIMERANGE => [0, 1416083300000] }
ROW COLUMN+CELL
key1 column=f1:a, timestamp=1416083294981, value=value3
key2 column=f1:a, timestamp=1416083299840, value=value4
To samo dotyczy kodu Java:
package org.example.test;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;
public class test {
public static void main (String[] args) throws IOException {
HTable table = new HTable(HBaseConfiguration.create(), "t1");
Scan s = new Scan();
s.setMaxVersions(1);
s.setTimeRange (0L, 1416083300000L);
ResultScanner scanner = table.getScanner(s);
for (Result rr = scanner.next(); rr != null; rr = scanner.next()) {
System.out.println(Bytes.toString(rr.getRow()) + " => " +
Bytes.toString(rr.getValue(Bytes.toBytes("f1"), Bytes.toBytes("a"))));
}
}
}
Należy pamiętać, że określając zakres maksymalną wartość czasu jest excluded, co oznacza, że jeśli chcesz dostać ostatnią wartość dla wszystkich kluczy z maksymalną datownika T, to powinno określać górną granicę zakresu do t + 1
Czy chcesz zrobić to w powłoce HBase lub napisać program do tego? Zobacz tutaj, jak zdobyć listę kluczy ze stołu: http://stackoverflow.com/questions/5218085/how-to-list-all-row-keys-in-an-hbase-table, dla każdego klucz można wydać 'get' i uzyskać znacznik czasu wpisy http://stackoverflow.com/questions/8321741/retrieving-timestamp-from-hbase-row, a następnie filtrować je w oparciu o swój stan – 0x0FFF