java客户端通过get方法获取Hbase的数据
2017-08-16 09:07
459 查看
public static void main(String[] args) throws MasterNotRunningException, IOException{
// TODO Auto-generated method stub
String tableName = "zrl_emp";
Configuration conf = HBaseConfiguration.create();
conf.set("hbase.master", "hdfs://Master.Hadoop:60000");
conf.set("hbase.rootdir", "hdfs://Master.Hadoop:9000/hbase");
conf.set("hbase.zookeeper.property.clientPort", "2181");
conf.set("hbase.zookeeper.quorum", "Master.Hadoop,Slave1.Hadoop");
Connection conn = ConnectionFactory.createConnection(conf);
Table table = conn.getTable(TableName.valueOf(tableName));
Get g = new Get(Bytes.toBytes("rowKey1"));
Result result = table.get(g);
byte [] value = result.getValue(Bytes.toBytes("personal data"), Bytes.toBytes("newColumnName2"));
byte[] value1 = result.getValue(Bytes.toBytes("personal data"), Bytes.toBytes("city"));
table.close();
System.out.println(result.toString());
System.out.println(Bytes.toString(value));
System.out.println(Bytes.toString(value1));
}
// TODO Auto-generated method stub
String tableName = "zrl_emp";
Configuration conf = HBaseConfiguration.create();
conf.set("hbase.master", "hdfs://Master.Hadoop:60000");
conf.set("hbase.rootdir", "hdfs://Master.Hadoop:9000/hbase");
conf.set("hbase.zookeeper.property.clientPort", "2181");
conf.set("hbase.zookeeper.quorum", "Master.Hadoop,Slave1.Hadoop");
Connection conn = ConnectionFactory.createConnection(conf);
Table table = conn.getTable(TableName.valueOf(tableName));
Get g = new Get(Bytes.toBytes("rowKey1"));
Result result = table.get(g);
byte [] value = result.getValue(Bytes.toBytes("personal data"), Bytes.toBytes("newColumnName2"));
byte[] value1 = result.getValue(Bytes.toBytes("personal data"), Bytes.toBytes("city"));
table.close();
System.out.println(result.toString());
System.out.println(Bytes.toString(value));
System.out.println(Bytes.toString(value1));
}
相关文章推荐
- 简单通过java的socket&serversocket以及多线程技术实现多客户端的数据的传输,并将数据写入hbase中
- Android系列之网络(一)----使用HttpClient发送HTTP请求(通过get方法获取数据)
- java中通过反射获取方法并且调用(getMethod和invoke深入)实践
- Android系列之网络(一)----使用HttpClient发送HTTP请求(通过get方法获取数据)
- Android系列之网络(一)----使用HttpClient发送HTTP请求(通过get方法获取数据)
- Android之网络----使用HttpClient发送HTTP请求(通过get方法获取数据)
- Android系列之网络(一)----使用HttpClient发送HTTP请求(通过get方法获取数据)
- java 反射机制(通过getGenericSuperclass()方法获取到父类泛型的类型)
- Android系列之网络(一)----使用HttpClient发送HTTP请求(通过get方法获取数据)
- (一)----使用HttpClient发送HTTP请求(通过get方法获取数据)
- Android系列之网络(一)----使用HttpClient发送HTTP请求(通过get方法获取数据)
- java通过url获取页面数据 java解析xml 基金净值接口使用方法
- Java Json解析,Java Web Json解析,Java Web服务端获取Json数据,客户端通过HTTP获取Json数据
- java中通过反射获取方法并且调用(getMethod和invoke深入)实践
- 获取客户端ip地址方法和通过curl在命令行提交post数据到服务器
- Android系列之网络(一)----使用HttpClient发送HTTP请求(通过get方法获取数据)
- java反射通过字段名获取set、get方法
- java中通过反射获取方法并且调用(getMethod和invoke深入)实践
- (一)----使用HttpClient发送HTTP请求(通过get方法获取数据)
- Android系列之网络(一)----使用HttpClient发送HTTP请求(通过get方法获取数据)