Filtr REST HBase (SingleColumnValueFilter)

Question

Nie mogę wymyślić, jak używać filtrów w interfejsie REST HBase (HBase 0.90.4-cdh3u3). Dokumentacja właśnie podaje definicję schematu dla "ciągu", ale nie pokazuje, jak z niego korzystać.

Tak, jestem w stanie to zrobić:

curl -v -H 'Content-Type: text/xml' -d '<Scanner startRow="ddo" stopRow="ddp" batch="1024"/>' 'http://hbasegw:8080/table/scanner' 

a następnie pobrać z

curl -s -H "Content-Type: text/xml" http://hbasegw:8080/table/scanner/13293426893883128482b | tidy -i -q -xml 

Ale teraz chcę użyć SingleColumnValueFilter i trzeba zakodować, że jakoś w XML. Czy ktoś ma na to przykład?

Dzięki, Mario

Answer 1

pól filtru w XML Scanner są sformatowane jako ciągi JSON. Ponieważ JSON dla filtru ma wiele cytatów, polecam użycie oddzielnego pliku dla parametru cur o parametrze -d, aby uniknąć pojedynczego cudzysłowu.

curl -v -H "Content-Type:text/xml" -d @args.txt http://hbasegw:8080/table/scanner

Jeżeli plik args.txt jest:

<Scanner startRow="cm93MDE=" endRow="cm93MDg=" batch="1024"> 
    <filter> 
    { 
     "latestVersion":true, "ifMissing":true, 
     "qualifier":"Y29sMQ==", "family":"ZmFtaWx5", 
     "op":"EQUAL", "type":"SingleColumnValueFilter", 
     "comparator":{"value":"MQ==","type":"BinaryComparator"} 
    } 
    </filter> 
</Scanner> 

Jak można dowiedzieć się, w jaki sposób filtr ciąg JSON powinien wyglądać? Oto prosta droga przez kod Javy, który wypluwa usztywniony filtr, biorąc pod uwagę standardowy obiekt filtrujący z Java API HBase.

SingleColumnValueFilter filter = new SingleColumnValueFilter(
    Bytes.toBytes("family"), 
    Bytes.toBytes("col1"), 
    CompareFilter.CompareOp.EQUAL, 
    Bytes.toBytes("1") 
); 
System.out.println(ScannerModel.stringifyFilter(filter)); 

Należy zauważyć, że JSON i XML wymagają danych zakodowanych w Base64. Przetestowałem powyższe polecenie zwijania na stole i działało dobrze.

Jeśli zastanawiasz się, tak, interfejs API REST dla skanerów nie jest jeszcze tak przyjazny dla programistów, jak tylko może być.