阅读量:8
要查询HBase表中的全部数据，可以使用Scan类来扫描整个表。以下是一个示例代码，用于查询名为"mytable"的HBase表中的全部数据：
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.client.Table; import org.apache.hadoop.hbase.util.Bytes; public class HBaseQueryExample { public static void main(String[] args) throws Exception { // 创建HBase配置对象 Configuration conf = HBaseConfiguration.create(); // 创建HBase连接对象 Connection connection = ConnectionFactory.createConnection(conf); // 创建表对象 TableName tableName = TableName.valueOf("mytable"); Table table = connection.getTable(tableName); try { // 创建扫描对象 Scan scan = new Scan(); // 执行扫描并获取结果集 ResultScanner scanner = table.getScanner(scan); // 遍历结果集并输出行键和列值 for (Result result : scanner) { byte[] row = result.getRow(); for (Cell cell : result.listCells()) { byte[] family = CellUtil.cloneFamily(cell); byte[] qualifier = CellUtil.cloneQualifier(cell); byte[] value = CellUtil.cloneValue(cell); System.out.println("Row: " + Bytes.toString(row) + ", Family: " + Bytes.toString(family) + ", Qualifier: " + Bytes.toString(qualifier) + ", Value: " + Bytes.toString(value)); } } } finally { // 关闭表和连接 table.close(); connection.close(); } } } 请确保在运行代码之前已经正确配置了HBase的相关环境，并替换代码中的"mytable"为你要查询的表名。运行代码后，将会遍历并输出表中的所有数据的行键、列族、列限定符和值。
