HBASE是基于Hadoop分布式系统构建的列模式数据库，要使Java连接到HBASE，请选择hadoop-common、hadoop-mapreduce-client-core、h base-- 需要hbase-core的几个jar包。这些jar包都位于maven仓库中，地址： https://mvn repository.com/artifact/org.Apache.Hadoop，pod （
！ - https://mvn repository.com/artifact/org.Apache.Hadoop---- dependencygroupidorg.Apache.Hadoop/groupidartifaction dependencydependencygroupidorg.Apache.Hadoop/groupidartifactidhadoop-MapReduce-client-core/artifactidvadoop ependencydependencygroupidorg.Apache.h base/groupidartifactidhbase-common/artifactidversion2.0. 5 de persion groupidartifactidhbase-client/artifactidversion2.0.5/version/dependency创建新的连接HBASE的类。 在此处，必须指定HBASE的所有DataNode节点。 (示例hbase的构建使用了3
importorg.Apache.Hadoop.conf.configuration； importorg.Apache.Hadoop.h base.client.connection； importorg.Apache.Hadoop.h base.client.connection factory； import java.io.IOException； publicclasshbaseutil { publicstaticconnectiongetconnect (throwsioexception )配置配置=new配置配置配置returnconnectionfactory.create connection (configuration )； 调用hbase相关表进行操作
importorg.Apache.Hadoop.h base.tablename； importorg.Apache.Hadoop.h base.client.connection； importorg.Apache.Hadoop.h base.client.put； importorg.Apache.Hadoop.h base.client.table； import java.io.IOException； import java.util.ArrayList； import java.util.List； publicclasstesthbase { privatestaticfinalstringtable _ name=' wuxiao long '； privatestaticfinalstringfamily _ name=' info '； privatestaticfinalstringrow _ key=' three '； publicstaticvoidmain (字符串[ ] args ) throwsioexception (连接连接=hbaseutil.getconnect )； table table=conn.gettable (tablename.value of ) table_name )； ListPut puts=new ArrayListPut (； putput=newput(row_key.getbytes )； put.add column (family _ name.getbytes (、' name'.getBytes )、' wuxiaolong'.getBytes ) )； put.add column (family _ name.getbytes (、' age'.getBytes )、' 30'.getBytes ) )； puts.add(put； table.put(puts； conn.close (； 在HBASE数据库中查询操作结果