流程

先建立conn

連接table

創(chuàng)建get或put

執(zhí)行相關(guān)操作

建立連接

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);

獲取table

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

獲取rowkey

String rowkey = null;

寫(xiě)入數(shù)據(jù)

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

讀取數(shù)據(jù)

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())); }

刪除數(shù)據(jù)

Delete delete = new Delete(Bytes.toBytes(rowkey));// option delete.addColumn(Bytes.toBytes("family"), Bytes.toBytes("column"));table.delete(delete);

Reference:

http://www.corejavaguru.com/bigdata/hbase-tutorial/hbase-java-client-api-examples

總結(jié)

以上是生活随笔為你收集整理的hbase java api的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。