博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
用java查询HBase中某表的一批数据
阅读量:6577 次
发布时间:2019-06-24

本文共 3304 字,大约阅读时间需要 11 分钟。

java代码如下:

package db.query;import java.io.IOException;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.client.HTable;import org.apache.hadoop.hbase.client.Result;import org.apache.hadoop.hbase.client.ResultScanner;import org.apache.hadoop.hbase.client.Scan;import org.apache.hadoop.hbase.filter.Filter;import org.apache.hadoop.hbase.filter.PrefixFilter;import org.apache.hadoop.hbase.util.Bytes;public class HBaseQuery {    public static void main(String[] args) {        Configuration conf = HBaseConfiguration.create();            conf = HBaseConfiguration.create();            conf.set("hbase.zookeeper.quorum", "192.168.1.154");            conf.set("hbase.zookeeper.property.clientPort", "2181");            conf.set("hbase.master", "192.168.1.154:6000");            String tableName = "car_table";            HTable table;        try {            table = new HTable(conf, tableName);            //设置查询条件            //使用前缀过滤器            Filter filter = new PrefixFilter(Bytes.toBytes("144860945858310137-"));            Scan scan = new Scan();            scan.setFilter(filter);//            scan.setStartRow(Bytes.toBytes("144860945858310137-0000000000000"));//            scan.setStopRow(Bytes.toBytes("144860945858310137-9999999999999"));            scan.addFamily(Bytes.toBytes("lte"));            scan.addColumn(Bytes.toBytes("lte"), Bytes.toBytes("cid"));            scan.addColumn(Bytes.toBytes("lte"), Bytes.toBytes("time"));            scan.addColumn(Bytes.toBytes("lte"), Bytes.toBytes("pci"));            scan.addColumn(Bytes.toBytes("lte"), Bytes.toBytes("st"));            scan.addColumn(Bytes.toBytes("lte"), Bytes.toBytes("ed"));            scan.addColumn(Bytes.toBytes("lte"), Bytes.toBytes("ta"));            scan.addColumn(Bytes.toBytes("lte"), Bytes.toBytes("lat"));            scan.addColumn(Bytes.toBytes("lte"), Bytes.toBytes("lng"));            ResultScanner results = table.getScanner(scan);            for(Result result: results){                String rowkey =  Bytes.toString(result.getRow());                String cid = Bytes.toString(result.getValue(Bytes.toBytes("lte"), Bytes.toBytes("cid")));                String time = Bytes.toString(result.getValue(Bytes.toBytes("lte"), Bytes.toBytes("time")));                                String pci = Bytes.toString(result.getValue(Bytes.toBytes("lte"), Bytes.toBytes("pci")));                String st = Bytes.toString(result.getValue(Bytes.toBytes("lte"), Bytes.toBytes("st")));                    String ed = Bytes.toString(result.getValue(Bytes.toBytes("lte"), Bytes.toBytes("ed")));                    String ta = Bytes.toString(result.getValue(Bytes.toBytes("lte"), Bytes.toBytes("ta")));                String lat = Bytes.toString(result.getValue(Bytes.toBytes("lte"), Bytes.toBytes("lat")));                String lng = Bytes.toString(result.getValue(Bytes.toBytes("lte"), Bytes.toBytes("lng")));                                    System.out.println("rowkey : "+rowkey+" cid : "+cid+", time: "+time+", pci: "+pci+", st: "+st+", ed: "+ed+", ta: "+ta+", lat: "+lat+", lon: "+lng);            }                    } catch (IOException e) {            // TODO Auto-generated catch block            e.printStackTrace();        }    }}

所需jar包如下:

转载地址:http://noyno.baihongyu.com/

你可能感兴趣的文章
109. Convert Sorted List to Binary Search Tree
查看>>
css3 animate 和关键帧 @-webkit-keyframes
查看>>
文字链接颜色设置
查看>>
图片转流
查看>>
ubunto应用软件
查看>>
Git初始化仓库
查看>>
HTML 标签说明
查看>>
锋利的jQuery-2--判断jQuery获取到的对象是否存在$().length
查看>>
linux 查询系统版本命令、查询端口号是否被占用命令
查看>>
java笔记八:IO流之字符流与字符缓冲流
查看>>
Docker 命令收集
查看>>
myeclipse注册码生成器
查看>>
怎样快速学好PHP技术之PHP学习方法总结
查看>>
《Java工程师成神之路-基础篇》Java基础知识——序列化(已完结)
查看>>
iOS App间相互跳转漫谈 part2
查看>>
Java CAS 原理剖析
查看>>
ISCC2014 writeup
查看>>
Kotlin 知识梳理(1) Kotlin 基础
查看>>
js正则表达式
查看>>
iOS socket通信,编解码,浮点型数据解析
查看>>