zoukankan      html  css  js  c++  java
  • Hbase之遍历获取数据

    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.hbase.HBaseConfiguration;
    import org.apache.hadoop.hbase.TableName;
    import org.apache.hadoop.hbase.client.*;
    import org.apache.hadoop.hbase.util.Bytes;
    import java.io.IOException;

    /**
    * 遍历获取数据
    */
    public class ScanAccessData {
    public static void main(String[] args) throws IOException {
    Configuration configuration = HBaseConfiguration.create();
    Connection connection = ConnectionFactory.createConnection(configuration);
    //建立表的连接
    Table table = connection.getTable(TableName.valueOf("testtable"));
    //创建一个空的Scan实例
    Scan scan1 = new Scan();
    //在行上获取遍历器
    ResultScanner scanner1 = table.getScanner(scan1);
    //打印行的值
    for (Result res : scanner1) {
    System.out.println(res);
    }
    //关闭释放资源
    scanner1.close();

    Scan scan2 = new Scan();
    //添加限定列族
    scan2.addFamily(Bytes.toBytes("colfam1"));
    ResultScanner scanner2 = table.getScanner(scan2);
    for (Result res : scanner2) {
    System.out.println(res);
    }
    scanner2.close();

    Scan scan3 = new Scan();
    //添加限定列族 列分隔 行偏移
    scan3.addColumn(Bytes.toBytes("colfam1"), Bytes.toBytes("col-5")).
    addColumn(Bytes.toBytes("colfam2"), Bytes.toBytes("col-33")).
    setStartRow(Bytes.toBytes("row-10")).
    setStopRow(Bytes.toBytes("row-20"));
    ResultScanner scanner3 = table.getScanner(scan3);
    for (Result res : scanner3) {
    System.out.println(res);
    }
    scanner3.close();

    Scan scan4 = new Scan();
    scan4.addColumn(Bytes.toBytes("colfam1"),
    Bytes.toBytes("col-5")).
    setStartRow(Bytes.toBytes("row-10")).
    setStopRow(Bytes.toBytes("row-20"));
    ResultScanner scanner4 = table.getScanner(scan4);
    for (Result res : scanner4) {
    System.out.println(res);
    }
    scanner4.close();

    Scan scan5 = new Scan();
    //添加倒序
    scan5.addColumn(Bytes.toBytes("colfam1"), Bytes.toBytes("col-5")).
    setStartRow(Bytes.toBytes("row-20")).
    setStopRow(Bytes.toBytes("row-10")).
    setReversed(true);
    ResultScanner scanner5 = table.getScanner(scan5);
    for (Result res : scanner5) {
    System.out.println(res);
    }
    scanner5.close();
    }
    }
  • 相关阅读:
    Unknown custom element: <el-container1>
    jQuery手机对话框插件
    告别2013,迎接2014
    淘宝开放平台主动通知的实现
    搭建JavaWeb服务器
    深入理解JavaScript执行上下文和执行栈
    为什么要选择学习Java?适合零基础的初学者的文章
    成为一名优秀的Java程序员9+难以置信的公式
    深入理解JavaScript作用域和作用域链
    JavaScript数据类型转换
  • 原文地址:https://www.cnblogs.com/similarface/p/5799460.html
Copyright © 2011-2022 走看看