hadoop2-HBase的Java API操作

发布时间：2020-12-14 06:32:20 所属栏目：Java 来源：网络整理

导读：Hbase提供了丰富的Java API，以及线程池操作，下面我用线程池来展示一下使用Java API操作Hbase。项目结构如下：我使用的Hbase的版本是 hbase-0.98.9-hadoop2-bin.tar.gz 大家下载后，可以拿到里面的lib目录下面的jar文件，即上所示的hbase-lib资源。接口

Hbase提供了丰富的Java API，以及线程池操作，下面我用线程池来展示一下使用Java API操作Hbase。

项目结构如下：

我使用的Hbase的版本是

hbase-0.98.9-hadoop2-bin.tar.gz

大家下载后，可以拿到里面的lib目录下面的jar文件，即上所示的hbase-lib资源。

接口类：

/hbase-util/src/com/b510/hbase/util/dao/HbaseDao.java

delRowsByRowKeys(String tableName,List }

实现类：

/hbase-util/src/com/b510/hbase/util/dao/impl/HbaseDaoImpl.java

@SuppressWarnings("deprecation" HbaseDaoImpl Configuration conf = defaultPoolSize = 5 HbaseDaoImpl( conf = conf.set("hbase.zookeeper.quorum","node1:2888,node2:2888,node3:2888" hAdmin = pool = HTablePool(conf,poolSize <= 0 ? } } } HTableInterface table = } (! HTableDescriptor tableDescriptor = HColumnDescriptor hColumnDescriptor = } System.out.println("The table [" + tableName + "] is created." } System.out.println("The table [" + tableName + "] is existing already." HTableInterface table = Put put = } System.out.println("Insert into table [" + tableName + "],Rowkey=[" + rowKey + "],Column=[" + columnFamily + ":" + column + "],Vlaue=[" + value + "]." } System.out.println("The table [" + tableName + "] does not exist." HTableInterface table = Get get = result = String columnName = "" String timeStamp = "" String columnFamily = "" String value = "" timeStamp = columnFamily = columnName = value = System.out.println("Get from table [" + tableName + "],Column=[" + columnFamily + ":" + columnName + "],Timestamp=[" + timeStamp + "],Vlaue=[" + value + "]." } } System.out.println("The table [" + tableName + "] does not exist." Scan scan = } System.out.println("The table [" + tableName + "] does not exist." HTableInterface table = ResultScanner results = String rowKey = "" String columnName = "" String timeStamp = ""

测试类：

/hbase-util/src/com/b510/hbase/util/dao/test/HbaseDaoTest.java

HbaseDao dao = HbaseDaoImpl(4 String tableName = "t_test" String columnFamilyName = "cf1" String[] CFs = String COLUMN_NAME_NAME = "name" String COLUMN_NAME_AGE = "age" System.out.println("=== create table ====" System.out.println("=== insert record ====" dao.addRow(tableName,"12345566",columnFamilyName,COLUMN_NAME_NAME,"Hongten" dao.addRow(tableName,COLUMN_NAME_AGE,"22" dao.addRow(tableName,"12345567","Tom" dao.addRow(tableName,"25" dao.addRow(tableName,"12345568","Jone" dao.addRow(tableName,"30" dao.addRow(tableName,"12345569","Jobs" dao.addRow(tableName,"24" System.out.println("=== get record ====" dao.getRow(tableName,"12345566" System.out.println("=== scan table ====" System.out.println("=== scan record by giving range ====" dao.getRowsByRange(tableName,"12345569" System.out.println("=== delete record ====" dao.delRow(tableName,"12345568" System.out.println("=== delete batch records ====" List rowKeys = ArrayList rowKeys.add("12345566" rowKeys.add("12345569" System.out.println("=== delete table ====" }

测试结果：

log4j:WARN No appenders could be found === create table ======= insert record =====[12345566],Column=[cf1:name],Vlaue==[12345567],Vlaue==[12345568],Vlaue==[12345569],Vlaue==== get record ======= scan table ======= scan record by giving range ======= delete record =====[12345568=== scan record by giving range ======= delete batch records =====[12345566=[12345569=== scan table ======= delete table ====

源码下载：

========================================================