import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.CellScanner;

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;

import java.util.ArrayList;

import java.util.List;

/**

 * Created by similarface on 16/8/22.

 * 这儿实现了一个类似于MySQL的Limit的功能

 */

public class RetrievesPartsRowWithOffsetLimit {

    public static void main(String args[]) throws IOException {

        Configuration configuration = HBaseConfiguration.create();

        Connection connection = ConnectionFactory.createConnection(configuration);

        //建立表的连接

        Table table = connection.getTable(TableName.valueOf("testtable"));

        Put put = new Put(Bytes.toBytes("5701"));

        for (int n = 1; n <= 1000; n++) {

            String num = String.format("%04d", n);

            put.addColumn(Bytes.toBytes("colfam1"), Bytes.toBytes("qual"+num), Bytes.toBytes("val" + num));

        }

        table.put(put);

        Get get1 = new Get(Bytes.toBytes("5701"));

        //要求最多返回10个Cell

        get1.setMaxResultsPerColumnFamily(10);

        Result result1 = table.get(get1);

        CellScanner scanner1 = result1.cellScanner();

        //返回1-10的数据集

        while (scanner1.advance()) {

            System.out.println("Get 1 Cell: " + scanner1.current());

        }

        Get get2 = new Get(Bytes.toBytes("5701"));

        //要求最多返回10行

        get2.setMaxResultsPerColumnFamily(10);

        //跳过前面100

        get2.setRowOffsetPerColumnFamily(100);

        Result result2 = table.get(get2);

        CellScanner scanner2 = result2.cellScanner();

        //返回101-110的数据

        while (scanner2.advance()) {

            System.out.println("Get 2 Cell: " + scanner2.current());

        }

    }

}

/**

 result:

 Get 1 Cell: 5701/colfam1:qual0001/1471842173521/Put/vlen=7/seqid=0

 Get 1 Cell: 5701/colfam1:qual0002/1471842173521/Put/vlen=7/seqid=0

 Get 1 Cell: 5701/colfam1:qual0003/1471842173521/Put/vlen=7/seqid=0

 Get 1 Cell: 5701/colfam1:qual0004/1471842173521/Put/vlen=7/seqid=0

 Get 1 Cell: 5701/colfam1:qual0005/1471842173521/Put/vlen=7/seqid=0

 Get 1 Cell: 5701/colfam1:qual0006/1471842173521/Put/vlen=7/seqid=0

 Get 1 Cell: 5701/colfam1:qual0007/1471842173521/Put/vlen=7/seqid=0

 Get 1 Cell: 5701/colfam1:qual0008/1471842173521/Put/vlen=7/seqid=0

 Get 1 Cell: 5701/colfam1:qual0009/1471842173521/Put/vlen=7/seqid=0

 Get 1 Cell: 5701/colfam1:qual0010/1471842173521/Put/vlen=7/seqid=0

 Get 2 Cell: 5701/colfam1:qual0101/1471842173521/Put/vlen=7/seqid=0

 Get 2 Cell: 5701/colfam1:qual0102/1471842173521/Put/vlen=7/seqid=0

 Get 2 Cell: 5701/colfam1:qual0103/1471842173521/Put/vlen=7/seqid=0

 Get 2 Cell: 5701/colfam1:qual0104/1471842173521/Put/vlen=7/seqid=0

 Get 2 Cell: 5701/colfam1:qual0105/1471842173521/Put/vlen=7/seqid=0

 Get 2 Cell: 5701/colfam1:qual0106/1471842173521/Put/vlen=7/seqid=0

 Get 2 Cell: 5701/colfam1:qual0107/1471842173521/Put/vlen=7/seqid=0

 Get 2 Cell: 5701/colfam1:qual0108/1471842173521/Put/vlen=7/seqid=0

 Get 2 Cell: 5701/colfam1:qual0109/1471842173521/Put/vlen=7/seqid=0

 Get 2 Cell: 5701/colfam1:qual0110/1471842173521/Put/vlen=7/seqid=0

 **/