hbase java api 查询_java api 查询hbase
考虑到Java代码一般就是查询hbase存储的hadoop运算的结果数据,下面记录下查询的简单范例代码
package com.lvmama.crm.web.controller.csVipManager;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
/**
* Created by zoubin on 2017-5-22.
*/
public class HbaseTest {
private Configuration configuration;
@Before
public void setUp(){
configuration = HBaseConfiguration.create();
configuration.set("hbase.zookeeper.quorum", "node3,node4,node5");//通过zookeeper关联上hbase
}
/**
* 根据rowkey查找数据
* @throws IOException
*/
@Test
public void getResult() throws IOException {
Get get = new Get(Bytes.toBytes("row1"));
HTable table = new HTable(configuration,Bytes.toBytes("test"));
Result result = table.get(get);
for(KeyValue keyValue: result.list()){
System.out.println("family :" + Bytes.toString(keyValue.getFamily()));//列簇名
System.out.println("qualifier :"+ Bytes.toString(keyValue.getQualifier()));//列名
System.out.println("value :"+Bytes.toString(keyValue.getValue()));//列对应的值
System.out.println("timestamp :" +keyValue.getTimestamp());//数据最后更新时间
System.out.println("---------------------------------");
}
}
/**
* 查询指定rowkey范围的数据
* @throws IOException
*/
@Test
public void getResults() throws IOException {
Scan scan = new Scan();
scan.setStartRow(Bytes.toBytes("row2"));
scan.setStopRow(Bytes.toBytes("row4"));//实验发现范围取[row2,row4),左闭右开
ResultScanner rs = null;
HTable table = new HTable(configuration, Bytes.toBytes("test"));
rs = table.getScanner(scan);
for(Result r : rs){
for (KeyValue kv : r.list()){
System.out.println("row:" + Bytes.toString(kv.getRow()));
System.out.println("family:"+ Bytes.toString(kv.getFamily()));
System.out.println("qualifier:"+ Bytes.toString(kv.getQualifier()));
System.out.println("value:" + Bytes.toString(kv.getValue()));
System.out.println("timestamp:" + kv.getTimestamp());
System.out.println("-------------------------------------------");
}
}
}
}
hbase java api 查询_java api 查询hbase相关推荐
- java api 设计_Java API设计实践
使你的API在模块化和非模块化Java环境中都可用 在优锐课的java学习分享中,对微服务有了更深层次的新概念.关于API设计实践一点就通了. 介绍 了解设计Java API时应应用的一些API设计实 ...
- java mysql语句_java mysql查询语句怎么写
展开全部 1:使用SHOW语句找出在服务器上当前存在什么数据32313133353236313431303231363533e4b893e5b19e31333363373766库: mysql> ...
- hbase java框架_Hadoop学习笔记—15.HBase框架学习(基础实践篇)
一.HBase的安装配置 1.1 伪分布模式安装 伪分布模式安装即在一台计算机上部署HBase的各个角色,HMaster.HRegionServer以及ZooKeeper都在一台计算机上来模拟. 首先 ...
- java 页面查询_JAVA页面浏览量查询api调用代码实例
代码描述:基于JAVA页面浏览量查询api调用代码实例 接口地址:http://www.juhe.cn/docs/api/id/51 1.[代码][Java]代码 import java.io.Buf ...
- java所参数查询_Java程序查询系统参数
Java程序查询系统参数 系统参数就是系统中设定的一些参数,比如系统名称.JVM的版本等.Java的程序可以跨平台执行,可以通过这些系统参数的值目前执行的环境是怎样的,然后程序在执行的时候可以根据不同 ...
- java api教程_Java api 入门教程 之 JAVA的文件操作
I/O类使用 由于在IO操作中,需要使用的数据源有很多,作为一个IO技术的初学者,从读写文件开始学习IO技术是一个比较好的选择.因为文件是一种常见的数据源,而且读写文件也是程序员进行IO编程的一个基本 ...
- java 百万数据查询_java一次性查询几十万,几百万数据解决办法
java查询一次性查询几十万,几百万数据解决办法 很早的时候写工具用的一个办法. 当时是用来把百万数据打包 成rar文件. 所以用了个笨办法. 希望高手指导一下,有什么好方法没有啊 1.先批量查出所有 ...
- java姓名模糊查询_java 模糊查询。(转)
package testSortAlgorithm; import java.util.ArrayList; import java.util.List; public class ListLike ...
- java多线程查询_java多线程查询
标签: 由于最近工作遇到性能问题,尝试研究用多线程来实现,结果速度快了好几倍 下面是多线程查询的部分代码,提供给大家参考下: 线程类: 带返回值的类要实现Callable接口,具体业务逻辑没有实现,只 ...
最新文章
- 模块化、层次化网络监控平台
- YOLOv3最全复现代码合集(含PyTorch/TensorFlow和Keras等)
- AndroidStudio设置不自动弹出 Documentation 窗口
- vlan为什么能隔离广播域_路由交换技术-VLAN原理及配置
- 【产品对比】Word开发工具Aspose.Words和Spire.Doc性能和优劣对比一览
- smpt authentification 配置
- 《树莓派渗透测试实战》——1.7 树莓派渗透测试场景
- 第二课 了解编程环境
- 深入浅出设计模式之工厂模式
- 手机安装 Linux 系统教程
- 微信小程序组件之间的传值
- C++标准委员会7月科隆会议中投票通过的特性
- [Vue warn] Extraneous non-emits event listeners (createSuccess) were passed to component but could
- 音频编码-G.711
- 四川师范大学自然地理(1-地球)90分以上版本
- JS的DOM操作3--删除事件,注册事件与冒泡⭐⭐⭐(附带动图案例)
- Node.js结合wechaty实现个人微信机器人助手
- 用MATLAB将bilibili缓存视频批量转换成MP4的方法
- 2022win7cf烟雾头最新调法
- mysql易百_MySQL Replace语句