溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要講解了Java操作Hbase的方法，內容清晰明了，對此有興趣的小伙伴可以學習一下，相信大家閱讀完之后會有幫助。
Java操作Hbase主要方法：
1.Configuration
在使用Java API時，Client端需要知道HBase的配置環境，如存儲地址，zookeeper等信息。
這些信息通過Configuration對象來封裝，可通過如下代碼構建該對象：
Configuration config = HBaseConfiguration.create();
在調用HBaseConfiguration.create()方法時，HBase首先會在classpath下查找hbase-site.xml文件，將里面的信息解析出來封裝到Configuration對象中，如果hbase-site.xml文件不存在，則使用默認的hbase-core.xml文件。
2.HBaseAdmin
HBaseAdmin用于創建數據庫表格，并管理表格的元數據信息，通過如下方法構建：
HBaseAdmin admin=new HBaseAdmin(config);
3.HTableDescriptor
在HTableDescriptor中，建立了一個表結構，HTableDescriptor封裝表格對象，對表格的增刪改查操作主要通過它來完成，構造方法如下：
HTableDescriptor table = new HTableDescriptor(TableName.valueOf(“表名”));
4.addFamily
addFamily用于建立表下的列簇，并存放到表結構，方法如下：
HColumnDescriptor base = new HColumnDescriptor(“列簇名”);
table.addFamily(base);
代碼如下：
首先建一個maven工程，導入依賴包導pom.xml
<dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-client</artifactId> <version>1.2.0</version> </dependency> <dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-common</artifactId> <version>1.2.0</version> </dependency> <dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-server</artifactId> <version>1.2.0</version> </dependency
1、創建表操作
public class HBaseClient {
public void createTable() throws IOException {
// 1. 創建配置
Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum","ip1");
//hbase主默認端口是60000
conf.set("hbase.master","ip1:60000");
//zookeeper客戶端的端口號2181
conf.set("hbase.zookeeper.property.clientPort","2181");
// 2. 創建連接
Connection conn = ConnectionFactory.createConnection(conf);
//3.獲得一個建表、刪表的對象hbaseAdmin()是繼承admin()
Admin admin = conn.getAdmin();
// 4. 創建表的描述信息
HTableDescriptor student = new HTableDescriptor(TableName.valueOf("表名"));
// 5. 添加列簇
student.addFamily(new HColumnDescriptor("列簇名1"));
student.addFamily(new HColumnDescriptor("列簇名2"));
// 6. 調用API進行建表操作
admin.createTable(student);
}
}2、判斷表是否存在
public void isTableExists() throws IOException {
// 1. 創建配置
Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum","ip1");
conf.set("hbase.zookeeper.property.clientPort","2181");
// 2. 創建連接
Connection conn = ConnectionFactory.createConnection(conf);
// 3. 創建admin
Admin admin = conn.getAdmin();
// 4. 調用API進行判斷表是否存在
System.out.println(admin.tableExists(TableName.valueOf("表名")));
}3、向表中插入數據
public void putData2Table() throws IOException {
// 1. 創建配置
Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum","ip1");
conf.set("hbase.zookeeper.property.clientPort","2181");
// 2. 創建連接
Connection conn = ConnectionFactory.createConnection(conf);
// 3. 創建Table類
Table student = conn.getTable(TableName.valueOf("表名"));
// 4. 創建Put類
Put put = new Put(Bytes.toBytes("1001"));
// 5. 向Put中添加 列簇，列名，值 注意：需要轉化成字節數組
put.addColumn(Bytes.toBytes("列簇1"),Bytes.toBytes("列1"),Bytes.toBytes("zhangsan"));
put.addColumn(Bytes.toBytes("列簇1"),Bytes.toBytes("列2"),Bytes.toBytes("female"));
put.addColumn(Bytes.toBytes("列簇2"),Bytes.toBytes("列3"),Bytes.toBytes("math"));
put.addColumn(Bytes.toBytes("列簇2"),Bytes.toBytes("列4"),Bytes.toBytes("89"));
// 6.調用API進行插入數據
student.put(put);
}4、查看一條數據
public void getDataFromTable() throws IOException {
// 1. 創建配置
Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum","ip1");
conf.set("hbase.zookeeper.property.clientPort","2181");
// 2. 創建連接
Connection conn = ConnectionFactory.createConnection(conf);
// 3. 創建Table類
Table student = conn.getTable(TableName.valueOf("表名"));
// 4. 創建 Get 類
Get get = new Get(Bytes.toBytes("1001"));
// 5.調用API進行獲取數據
Result result = student.get(get);
// 6. 將返回的結果進行遍歷輸出
Cell[] cells = result.rawCells();
for (Cell cell : cells) {
System.out.println("rowkey ："+Bytes.toString(CellUtil.cloneRow(cell)));
System.out.println("列簇 ："+Bytes.toString(CellUtil.cloneFamily(cell)));
System.out.println("列名 ："+Bytes.toString(CellUtil.cloneQualifier(cell)));
System.out.println("值 ："+Bytes.toString(CellUtil.cloneValue(cell)));
System.out.println("----------------");
}
}5、刪除表操作
public void dropTable() throws IOException {
// 1. 創建配置
Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum","ip1");
conf.set("hbase.zookeeper.property.clientPort","2181");
// 2. 創建連接
Connection conn = ConnectionFactory.createConnection(conf);
// 3. 創建admin
Admin admin = conn.getAdmin();
// 4. 調用API禁用表
admin.disableTable(TableName.valueOf("表名"));
// 5. 調用API刪除表
admin.deleteTable(TableName.valueOf("表名"));
}
}6、刪除hbase中的table里面的rowkey
public static void deleteRow(String tableName,String rowKey) throws Exception{
HTable hTable = new HTable(configuration,tableName);
Delete delete = new Delete(rowKey.getBytes());
List<Delete> list = new ArrayList<Delete>();
list.add(delete);
hTable.delete(list);
} 7、查詢row = rowKey的數據
public static void getRow(String tableName,String rowKey) throws Exception{
HTable hTable = new HTable(configuration, tableName);
Get get = new Get(rowKey.getBytes());
Result result = hTable.get(get);
for(KeyValue value:result.raw()){
System.out.println("cf:"+new String(value.getFamily())+new String(value.getQualifier())+"="+new String(value.getValue()));
}
}8、查詢rowkey在startRow和endRow之間的數據，及rowkey的范圍查詢
Put、Delete與Get對象都是Row的子類，從該繼承關系中我們就可以了解到Get、Delete與Pu對象本身就只能進行單行的操作，
HBase客戶端還提供了一套能夠進行全表掃描的API，方便用戶能夠快速對整張表進行掃描，以獲取想要的結果—scan：
public static void getBetweenRow(String tableName,String startRow,String stopRow) throws Exception{
HTable table = new HTable(configuration, tableName);
Scan scan = new Scan();
scan.addColumn("cf1".getBytes(), "colum1".getBytes());
scan.addColumn("cf1".getBytes(), "colum2".getBytes());
scan.addColumn("cf1".getBytes(), "colum3".getBytes());
scan.setStartRow(startRow.getBytes());
scan.setStopRow(stopRow.getBytes());
ResultScanner scanner = table.getScanner(scan);
for(Result result:scanner){
for(KeyValue value:result.raw()){
System.out.println("cf:"+new String(value.getFamily())+new String(value.getQualifier())+"="+new String(value.getValue()));
}
}
} 9、批量寫入
public <T> void puts(String tableName, Map<String, Object> items) {
if (items == null || items.isEmpty()) {
LOG.error("[HBase] Adding null/empty item map!");
return;
}
int maxSize = 10000;
Table table = null;
try {
table = con.getTable(TableName.valueOf(tableName));
int eachSize = Math.min(maxSize, items.size());
List<Put> puts = new ArrayList<Put>(eachSize);
int handled = 0;
for (Entry<String, Object> entry : items.entrySet()) {
String ultimateRowKey = getHashedID(entry.getKey());
Object value = entry.getValue();
if (ultimateRowKey == null || ultimateRowKey.isEmpty()) {
LOG.error("[HBase] Adding null/empty hashed key! Original key is " + entry.getKey());
handled++;
continue;
}
Put put = new Put(Bytes.toBytes(ultimateRowKey));
put.addColumn(Bytes.toBytes(familyName1), Bytes.toBytes("ab"), Bytes.toBytes(value .getAb()));
put.addColumn(Bytes.toBytes(familyName1), Bytes.toBytes("dt"), Bytes.toBytes(value .getDt()));
put.addColumn(Bytes.toBytes(familyName1), Bytes.toBytes("hb"), Bytes.toBytes(value .getHb()));
Gson gson = new Gson();
String valuestr = gson.toJson(value);
put.addColumn(Bytes.toBytes(familyName2), Bytes.toBytes("js"), Bytes.toBytes(valuestr));
puts.add(put);
handled++;
// 每隔10000,寫一次
if (handled == eachSize) {
LOG.info("[HBase] Adding " + eachSize + "rows!");
table.put(puts);
puts = new ArrayList<Put>(eachSize);
}
}
if (puts.size() > 0)
table.put(puts);
} catch (IOException e) {
LOG.error("[HBase] Error while putting data " + e.getMessage());
} finally {
try {
if (table != null)
table.close();
} catch (IOException e) {
LOG.error("[HBase] Error while closing table " + e.getMessage());
}
}
}看完上述內容，是不是對Java操作Hbase的方法有進一步的了解，如果還想學習更多內容，歡迎關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
