2016-04-01 42 views
0

HBase üzerinde filtreler çalışıyorum ve şu anda SingleColumnValueFilter ile takılıyorum.SingleColumnValueFilter, HBASE hatası veriyor

İşte denedim sorgusu:

ERROR: Incorrect filter string SingleColumnValueFilter(=, '19068PA', 'cf1', 'RateExpirationDate')

birisi bana yardımcı olabilir:

scan 'hi_rate', {COLUMNS => 'cf1:RateExpirationDate', LIMIT => 10, FILTER => "SingleColumnValueFilter(=,'19068PA','cf1','RateExpirationDate')"} 

scan 'hi_rate', {LIMIT => 10, FILTER => "SingleColumnValueFilter(=,'19068PA','cf1','RateExpirationDate')"} 

scan 'hi_rate', {LIMIT => 10, FILTER => "SingleColumnValueFilter('cf1','RateExpirationDate',=,'19068PA')"} 

Hepsi aynı hatayı verir?

import org.apache.hadoop.hbase.filter.CompareFilter 
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter 
import org.apache.hadoop.hbase.util.Bytes 

scan 'table_name', {FILTER => SingleColumnValueFilter.new(Bytes.toBytes('column_family_name'), Bytes.toBytes('column_name'), CompareFilter::CompareOp.valueOf('EQUAL'), Bytes.toBytes('value')) } 

değişim tablo_ismi, column_family_name ve sütun_ismi sizin tablosuna göre şöyledir: Ben HBase masaya sorgulamak için aşağıdaki

cevap

0

genel sözdizimi.

table_name = hi_rate 
column_family_name = cf1 
column_name = RateExpirationDate 
value = 19068PA 

sonra sorgu olur varsayarak

import org.apache.hadoop.hbase.filter.CompareFilter 
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter 
import org.apache.hadoop.hbase.util.Bytes 

scan 'hi_rate', {FILTER => SingleColumnValueFilter.new(Bytes.toBytes('cf1'), Bytes.toBytes('RateExpirationDate'), CompareFilter::CompareOp.valueOf('EQUAL'), Bytes.toBytes('19068PA')) } 
İlgili konular