java从hbase读取数据
时间: 2023-09-22 12:07:53 浏览: 97
java 通过thrift-0.9.1读取hbase表数据
4星 · 用户满意度95%
在Java中,可以使用HBase API来从HBase中读取数据。以下是一个示例代码,演示如何从HBase中读取数据:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
public class HBaseReader {
public static void main(String[] args) throws Exception {
// 创建HBase配置对象
Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum", "localhost"); // 设置ZooKeeper地址
// 创建HBase连接对象
Connection conn = ConnectionFactory.createConnection(conf);
// 获取表对象
Table table = conn.getTable(TableName.valueOf("mytable"));
// 创建Get对象
Get get = new Get(Bytes.toBytes("rowkey1"));
// 读取数据
Result result = table.get(get);
byte[] value = result.getValue(Bytes.toBytes("cf"), Bytes.toBytes("column1"));
// 输出数据
System.out.println(Bytes.toString(value));
// 关闭表和连接
table.close();
conn.close();
}
}
```
在上面的代码中,我们首先创建了一个HBase配置对象,并将ZooKeeper地址设置为"localhost"。接着,我们创建了一个HBase连接对象,并从该连接获取了表对象。然后,我们创建了一个Get对象,并使用该对象读取了一行数据。最后,我们从Result对象中获取了列族为"cf"、列名为"column1"的值,并将其输出。最后,我们关闭了表和连接对象。
阅读全文