时间: 2020-09-3|tag:40次围观|0 条评论

 

1.Hbase 根据rowkey 查询

conf的配置信息如下:

        conf = new Configuration();        conf.set("hbase.zookeeper.quorum", "192.168.50.253:2181");        conf.set("hbase.rootdir", "hdfs://192.168.50.253:9000/hbase");

 

public ArrayList<String>  getRoutes(String rowkey,String tablename) throws IOException {        HTable hTable = new HTable(conf, tablename);//traffic_route        Get get = new Get(rowkey.getBytes());        Result r = hTable.get(get);        KeyValue[] kv = r.raw();  // 行健对应的值.        ArrayList<String> list = new ArrayList<>();        if (kv.length > 0) {            String ss = kv[0].getValue().toString();            DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");            Date tempDay = new Date();            tempDay = null;            int sum = 0;            String tempDate = "";            String mapStringValue = "";            for (int i = 0; i < kv.length; i++) {                String value = new String(kv[i].getValue());//            System.out.println("value = " + value);                String[] station = value.split("--");//            System.out.println(station[0]);                String[] date = station[0].split(" ");                try {                    Date day = sdf.parse(date[0]);                    if (tempDay == null) {                        tempDay = day;                    }                    if ((day.compareTo(tempDay) == 0)) {                        tempDate = date[0];                        mapStringValue = mapStringValue + station[1] + "-";                    } else {                        Map<String, String> map = new HashMap<>();                        map.put(tempDate, mapStringValue);                        list.add(mapStringValue);                        mapStringValue = "";                        tempDay = day;                        mapStringValue += station[1] + "-";                    }                } catch (ParseException e) {                    e.printStackTrace();                }            }//        System.out.println("list  = " + list.size());            Map<String, String> map = new HashMap<>();            map.put(tempDate, mapStringValue);            list.add(mapStringValue);            mapStringValue = "";        }//        System.out.println("list.get(0)  = " + list.get(0));//        System.out.println("list.get(1)  = " + list.get(1));            if (list.size() == 0) {                System.out.println("取出数据为空");            } else {                System.out.println("获取数据成功");            }            return list;        }

文章转载于:https://www.cnblogs.com/chaoren399/p/5004555.html

原著是一个有趣的人,若有侵权,请通知删除

本博客所有文章如无特别注明均为原创。
复制或转载请以超链接形式注明转自起风了,原文地址《hadoop之根据Rowkey从HBase中查询数据
   

还没有人抢沙发呢~