向HBase中追加数据-Append

package hbasebook.ch3;

import hbasebook.util.HBaseHelper;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Append;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

public class AppendExample {

    public static void main(String[] args) throws IOException {
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum","10.1.195.181:2181");

        HBaseHelper helper = HBaseHelper.getHelper(conf);
        helper.dropTable("testtable");
        helper.createTable("testtable",100,"colfam1","colfam2");
        helper.put("testtable",
                new String[] { "row1" },
                new String[] { "colfam1" },
                new String[] { "qual1" },
                new long[]   { 1 },
                new String[] { "oldvalue" });
        System.out.println("Before append call ......");
        helper.dump("testtable",new String[]{"row1"},null,null);

        Connection connection = ConnectionFactory.createConnection(conf);
        Table table = connection.getTable(TableName.valueOf("testtable"));

        Append append = new Append(Bytes.toBytes("row1"));
        append.add(Bytes.toBytes("colfam1"),Bytes.toBytes("qual1"),Bytes.toBytes("newvalue"));
        append.add(Bytes.toBytes("colfam1"), Bytes.toBytes("qual2"), Bytes.toBytes("anothervalue"));

        table.append(append);
        System.out.println("After append call.....");
        helper.dump("testtable",new String[]{"row1"},null,null);
        table.close();
        connection.close();
        helper.close();
    }
}