hbase访问方式之java api

网友投稿 261 2023-03-28


hbase访问方式之java api

Hbase的访问方式

1、Native Java API:最常规和高效的访问方式;

2、HBase Shell:HBase的命令行工具,最简单的接口,适合HBase管理使用;

3、Thrift Gateway:利用Thrift序列化技术,支持C++,php,python等多种语言,适合其他异构系统在线访问HBase表数据;

4、REST Gateway:支持REST 风格的Http API访问HBase, 解除了语言限制;

5、MapReduce:直接使用MapReduce作业处理Hbase数据;

6、使用Pig/hive处理Hbase数据。

常用java API的用法:

1、加载配置

Configuration config = HBaseConfiguration.create();

//可以自定义配置,也可以从自定义配置文件中读取

/*config.set("hbase.zookeeper.property.clientPort", "4181");

config.set("hbase.zookeeper.quorum", "hadoop.datanode5.com,hadoop.datanode2.com,hadoop.datanode3.com");

config.set("hbase.master", "hadoop.datanode3.com\\:600000");*/

2、表的创建、表信息修改、表删除

HBaseAdmin admin = new HBaseAdmin(config);

//创建表

HTableDescriptor htd = new HTableDescriptor(tableName);

htd.addFamily(new HColumnDescriptor("cf1"));

htd.addFamily(new HColhttp://umnDescriptor("cf2"));

admin.createTable(htd);

//修改表信息

admin.disableTable(tableName);

// modifying existing ColumnFamily

admin.modifyColumn(tableName, new HColumnDescriptor("cf1"));

admin.enableTable(tableName);

//删除表

admin.disableTable(Bytes.toBytes(tableName));

admin.deleteTable(Bytes.toBytes(tableName));

3、添加记录

/** 在多次使用时,建议用HTablePool

HTable table = new HTable(config, tableName);

=>

HTablePool pool = new HTablePool(config, 1000);

HTableInterface table = pool.getTable(tableName);*/

HTable table = new HTable(config, tableName);

/**

* 在插入操作时,默认不适用任何缓存

* 可自定义使用缓存,以及缓存大小

* 每个任务最后需要手工调用 flushCommits();

*/

/*table.setAutoFlush(false);

table.setWriteBufferSize(1024);*/

Put put1 = new Put(Bytes.toBytes(rowKey));

if (ts == 0) {

put1.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), Bytes.toBytes(value));

} else {

//自定义版本时,从自定义的版本号,类型为long

put1.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), ts,Bytes.toBytes(value));

}

table.put(put1);

//table.flushCommits();

4、查询,根据Rowkey查询

Get get1 = new Get(Bytes.toBytes(rowKey));

Result result = table.get(get1);

System.out.http://println("get result:" + Bytes.toString(result.getValue(Bytes.toBytes(family), Bytes.toBytes(qualifier))));

Result[] result = table.get(List

5、查询,指定条件和rowkey区间查询

Scan scan = new Scan();

//默认缓存大小为1,设置成一个合理的值,可以减少scan过程中next()的时间开销,代价是客户端的内存

scan.setCaching(500);

scan.setCacheBlocks(false);

//根据startRowKey、endRowKey查询

//Scan scan = new Scan(Bytes.toBytes("startRowKey"), Bytes.toBytes("endRowKey"));

//rowKey之外的过滤条件,在List中可以add;

/**List filters = new ArrayList();

Filter filter = new SingleColumnValueFilter("familyName".getBytes(),

"qualifierName".getBytes(),

CompareOp.EQUAL,

Bytes.toBytes("value"));

filters.add(filter);

scan.setFilter(new FilterList(filters));*/

ResultScanner scanner = table.getScanner(scan);

System.out.println("scan result list:");

for (Result result : scanner) {

System.out.println(Bytes.toString(result.getRow()));

System.out.println(Bytes.toString(result.getValue(Bytes.toBytes("data"), Bytes.toBytes("data1"))));

System.out.println(Bytes.toString(result.getValue(Bytes.toBytes("data"), Bytes.toBytes("data2"))));

}

scanner.close();

总结

以上所述是给大家介绍的hbase访问方式之java api,希望对大家有所帮助,如果大家有任何疑问请给我留言,会及时回复大家的。在此也非常感谢大家对我们网站的支持!

5、查询,指定条件和rowkey区间查询

Scan scan = new Scan();

//默认缓存大小为1,设置成一个合理的值,可以减少scan过程中next()的时间开销,代价是客户端的内存

scan.setCaching(500);

scan.setCacheBlocks(false);

//根据startRowKey、endRowKey查询

//Scan scan = new Scan(Bytes.toBytes("startRowKey"), Bytes.toBytes("endRowKey"));

//rowKey之外的过滤条件,在List中可以add;

/**List filters = new ArrayList();

Filter filter = new SingleColumnValueFilter("familyName".getBytes(),

"qualifierName".getBytes(),

CompareOp.EQUAL,

Bytes.toBytes("value"));

filters.add(filter);

scan.setFilter(new FilterList(filters));*/

ResultScanner scanner = table.getScanner(scan);

System.out.println("scan result list:");

for (Result result : scanner) {

System.out.println(Bytes.toString(result.getRow()));

System.out.println(Bytes.toString(result.getValue(Bytes.toBytes("data"), Bytes.toBytes("data1"))));

System.out.println(Bytes.toString(result.getValue(Bytes.toBytes("data"), Bytes.toBytes("data2"))));

}

scanner.close();

总结

以上所述是给大家介绍的hbase访问方式之java api,希望对大家有所帮助,如果大家有任何疑问请给我留言,会及时回复大家的。在此也非常感谢大家对我们网站的支持!


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:详解Spring mvc DispatchServlet 实现机制
下一篇:常见的几个接口管理平台(常见的几个接口管理平台是)
相关文章

 发表评论

暂时没有评论,来抢沙发吧~