hbase java api

1
2
3
4
5
6
7
8
9
10
import org.apache.hadoop.hbase.client.*;
Connection conn = null;
Configuration conf = HBaseConfiguration.create();
conf.setStrings("hbase.zookeeper.quorum", "192.168.0.1，192.168.0.2");
conf.setStrings("hbase.zookeeper.property.clientPort", "2181");
conf.setStrings("hbase.client.retries.number", "3");
conf.setStrings("hbase.rpc.timeout", "10000");
conf.setStrings("hbase.client.operation.timeout", "30000");
conn = ConnectionFactory.createConnection(conf);

1
2
3
Table table = null;
table = connection.getTable(TableName.valueOf("table"));

1
2
String rowkey = null;

1
2
3
4
5
Put put = new Put(Bytes.toBytes(rowkey));
// option
put.addColumn(Bytes.toBytes("family"), Bytes.toBytes("column"), Bytes.toBytes("value"));
table.put(put);

1
2
3
4
5
6
Get get = new Get(Bytes.toBytes(rowkey));
Result result = table.get(get);
for (Map.Entry<byte[], byte[]> entry: result.getFamilyMap(Bytes.toBytes("family")).entrySet()) {
System.out.println(Bytes.toBytes(entry.getKey()));
}

1
2
3
4
5
Delete delete = new Delete(Bytes.toBytes(rowkey));
// option
delete.addColumn(Bytes.toBytes("family"), Bytes.toBytes("column"));
table.delete(delete);