Hbase的java_API操作是怎样的
Hbase的java_API操作是通过java程序来操作Hbase数据库的。 Hbase的java_API操作主要包括以下几个部分:
1. 创建Hbase配置文件
2. 创建Hbase连接
3. 执行Hbase操作
4. 关闭Hbase连接
下面我们就通过一个简单的例子来说明Hbase的java_API操作。
首先我们需要创建一个Hbase的配置文件,文件名为“hbase-site.xml”,文件内容如下:
然后我们创建一个java程序来操作Hbase数据库。
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.client.HTable; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.util.Bytes; public class HbaseTest { public static void main(String[] args) throws Exception { //创建Hbase配置文件 Configuration conf = HBaseConfiguration.create(); //创建Hbase连接 HTable table = new HTable(conf, "test"); //执行Hbase操作 Put put = new Put(Bytes.toBytes("row1")); put.add(Bytes.toBytes("colfam1"), Bytes.toBytes("qual1"), Bytes.toBytes("val1")); put.add(Bytes.toBytes("colfam1"), Bytes.toBytes("qual2"), Bytes.toBytes("val2")); table.put(put); //关闭Hbase连接 table.close(); } }
上面的例子中我们使用java程序来操作Hbase数据库,通过Hbase的java_API我们可以很方便的对Hbase数据库进行操作。
相关文章