package rest;

 import org.apache.hadoop.conf.Configuration;

 import org.apache.hadoop.hbase.HBaseConfiguration;

 import org.apache.hadoop.hbase.client.Get;

 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.rest.client.Client;

 import org.apache.hadoop.hbase.rest.client.Cluster;

 import org.apache.hadoop.hbase.rest.client.RemoteHTable;

 import org.apache.hadoop.hbase.util.Bytes;

 import util.HBaseHelper;

 import java.io.IOException;

 /**

  * Created by root on 15-1-9.

  */

 public class RestExample {

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

         Configuration conf = HBaseConfiguration.create();

         HBaseHelper helper = HBaseHelper.getHelper(conf);

         helper.dropTable("testtable");

         helper.createTable("testtable", "colfam1");

         System.out.println("Adding rows to table...");

         helper.fillTable("testtable", 1, 10, 5, "colfam1");

         Cluster cluster=new Cluster();

         cluster.add("hadoop",8080);

         Client client=new Client(cluster);

         RemoteHTable table=new RemoteHTable(client,"testtable");

         Get get = new Get(Bytes.toBytes("row-30"));

         get.addColumn(Bytes.toBytes("colfam1"), Bytes.toBytes("col-3"));

         Result result1 = table.get(get);

         System.out.println("Get result1: " + result1);

         Scan scan = new Scan();

         scan.setStartRow(Bytes.toBytes("row-10"));

         scan.setStopRow(Bytes.toBytes("row-15"));

         scan.addColumn(Bytes.toBytes("colfam1"), Bytes.toBytes("col-5"));

         ResultScanner scanner = table.getScanner(scan);

         for (Result result2 : scanner) {

             System.out.println("Scan row[" + Bytes.toString(result2.getRow()) +

                     "]: " + result2);

         }

     }

 }