阅读量:2
在HBase中,可以通过使用Scan或Get操作来查询某列的值。
使用Scan操作:
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
public class HBaseQuery {
public static void main(String[] args) throws Exception {
Configuration config = HBaseConfiguration.create();
Connection connection = ConnectionFactory.createConnection(config);
TableName tableName = TableName.valueOf("your_table_name");
Table table = connection.getTable(tableName);
Scan scan = new Scan();
scan.addColumn(Bytes.toBytes("your_column_family"), Bytes.toBytes("your_column"));
ResultScanner scanner = table.getScanner(scan);
for (Result result : scanner) {
byte[] value = result.getValue(Bytes.toBytes("your_column_family"), Bytes.toBytes("your_column"));
String valueString = Bytes.toString(value);
System.out.println("Value: " + valueString);
}
scanner.close();
table.close();
connection.close();
}
}
使用Get操作:
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
public class HBaseQuery {
public static void main(String[] args) throws Exception {
Configuration config = HBaseConfiguration.create();
Connection connection = ConnectionFactory.createConnection(config);
TableName tableName = TableName.valueOf("your_table_name");
Table table = connection.getTable(tableName);
Get get = new Get(Bytes.toBytes("your_row_key"));
get.addColumn(Bytes.toBytes("your_column_family"), Bytes.toBytes("your_column"));
Result result = table.get(get);
byte[] value = result.getValue(Bytes.toBytes("your_column_family"), Bytes.toBytes("your_column"));
String valueString = Bytes.toString(value);
System.out.println("Value: " + valueString);
table.close();
connection.close();
}
}
在上面的代码中,需要替换your_table_name、your_column_family、your_column和your_row_key为实际的表名、列族、列和行键。
以上就是关于“hbase如何查询某列的值”的相关介绍,筋斗云是国内较早的云主机应用的服务商,拥有10余年行业经验,提供丰富的云服务器、租用服务器等相关产品服务。云服务器资源弹性伸缩,主机vCPU、内存性能强悍、超高I/O速度、故障秒级恢复;电子化备案,提交快速,专业团队7×24小时服务支持!
简单好用、高性价比云服务器租用链接:https://www.jindouyun.cn/product/cvm