Hbase scan通过rowkey条件查询

Configuration config = new Configuration();
config.set("hbase.zookeeper.quorum", "10.1.1.1");//需根据hbase配置进行设置
HBaseConfiguration hbaseConfig = new HBaseConfiguration(config); Scan scan =
new Scan(); scan.setStartRow(Bytes.toBytes(time1+uid));
scan.setStopRow(Bytes.toBytes(time2+uid)); Filter filter = new
RowFilter(CompareFilter.CompareOp.EQUAL,new RegexStringComparator(".*"+uid));
scan.setFilter(filter); ResultScanner rs = null; HTable table = new
HTable(hbaseConfig, Bytes.toBytes(tableName)); String rowkey = null; rs =
table.getScanner(scan); for (Result r : rs) { for (KeyValue kv : r.list()) {
rowkey = Bytes.toString(kv.getRow()); System.out.println(rowkey); } }

一般rowkey的名字是uuid+time. 如果只想用uuid模糊查询，可以这样。

public static List<Map<String,String>> getList(String tableName,String
starttime,String stoptime,String uuid,String muuid) throws IOException{
HTablePool pool = new HTablePool(configuration, 1000); uuid =
"285836d1-cc0f-11e7-982d-00163e32a1d5"; /* Filter filter1 = new
SingleColumnValueFilter(Bytes .toBytes("MpsId"), null, CompareOp.EQUAL, Bytes
.toBytes(muuid));*/ //时间段查询 Scan scan = new Scan();
scan.addFamily(Bytes.toBytes("automate"));
scan.setStartRow(Bytes.toBytes(uuid+"_"+starttime));
scan.setStopRow(Bytes.toBytes(uuid+"_"+stoptime)); // scan.setFilter(filter1);
List<Map<String, String>> list = new ArrayList<>(); Map<String, String> maps =
new LinkedHashMap<>(); ResultScanner scanner1 =
pool.getTable(tableName).getScanner(scan); //ResultScanner scanner1 =
table.getScanner(scan); for (Result res : scanner1) { Map<String, String> map =
new LinkedHashMap<>(); System.out.println("==="+res.toString()); for (KeyValue
kv : res.raw()) { //测量值 if(new String(kv.getQualifier()).equals("MeasValue")){
System.err.println( new String(kv.getQualifier()) + ":" +
(int)(Float.parseFloat(new String(kv.getValue()))*100)/100.0); map.put(new
String(kv.getQualifier()), new String(kv.getValue())); } //差值 if(new
String(kv.getQualifier()).equals("DiffValue")){ System.err.println( new
String(kv.getQualifier()) + ":" + (int)(Float.parseFloat(new
String(kv.getValue()))*100)/100.0); map.put(new String(kv.getQualifier()), new
String(kv.getValue())); } //累计 if(new
String(kv.getQualifier()).equals("AccValue")){ System.err.println( new
String(kv.getQualifier()) + ":" + (int)(Float.parseFloat(new
String(kv.getValue()))*100)/100.0); map.put(new String(kv.getQualifier()), new
String(kv.getValue())); } //时间 if(new
String(kv.getQualifier()).equals("MeasTime")){ System.err.println( new
String(kv.getQualifier()) + ":" + new String(kv.getValue())); map.put(new
String(kv.getQualifier()), new String(kv.getValue())); } if(new
String(kv.getQualifier()).equals("CH1")){ System.err.println( new
String(kv.getQualifier()) + ":" + new String(kv.getValue())); } if(new
String(kv.getQualifier()).equals("CH2")){ System.err.println( new
String(kv.getQualifier()) + ":" + new String(kv.getValue())); } if(new
String(kv.getQualifier()).equals("CH3")){ System.err.println( new
String(kv.getQualifier()) + ":" + new String(kv.getValue())); } if(new
String(kv.getQualifier()).equals("CH1")){ System.err.println( new
String(kv.getQualifier()) + ":" + new String(kv.getValue())); } if(new
String(kv.getQualifier()).equals("CH2")){ System.err.println( new
String(kv.getQualifier()) + ":" + new String(kv.getValue())); } if(new
String(kv.getQualifier()).equals("CH3")){ System.err.println( new
String(kv.getQualifier()) + ":" + new String(kv.getValue())); } if(new
String(kv.getQualifier()).equals("V0")){ System.err.println( new
String(kv.getQualifier()) + ":" + new String(kv.getValue())); } } }
scanner1.close(); list.add(maps); return list; }
以上是实现通过时间段查询hbase里的数据。

注意：rowkey必须是跟时间信息的。如： new SimpleDateFormat("yyyy-MM-dd
hh:mm:ss:00").format(new Date())+name形式。
 

• « 上一篇：MySql 数据类型
• » 下一篇：【管理】DevOps的思考