hbase數據查詢如何統計數量

在HBase中，你可以使用Scan或Get操作來查詢數據并統計數量。下面是兩種方法的示例：

方法1：使用Scan操作

import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;

public class HBaseCount {
    public static void main(String[] args) throws Exception {
        // 創建HBase配置對象
        Configuration conf = HBaseConfiguration.create();

        // 創建連接對象
        Connection connection = ConnectionFactory.createConnection(conf);

        // 獲取表對象
        TableName tableName = TableName.valueOf("your_table_name");
        Table table = connection.getTable(tableName);

        // 創建掃描對象
        Scan scan = new Scan();
        scan.setBatch(100); // 設置批處理大小

        // 執行掃描操作
        ResultScanner scanner = table.getScanner(scan);

        // 統計數量
        int count = 0;
        for (Result result : scanner) {
            count++;
        }

        // 關閉資源
        scanner.close();
        table.close();
        connection.close();

        System.out.println("Total count: " + count);
    }
}

方法2：使用Get操作

import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;

public class HBaseCount {
    public static void main(String[] args) throws Exception {
        // 創建HBase配置對象
        Configuration conf = HBaseConfiguration.create();

        // 創建連接對象
        Connection connection = ConnectionFactory.createConnection(conf);

        // 獲取表對象
        TableName tableName = TableName.valueOf("your_table_name");
        Table table = connection.getTable(tableName);

        // 創建Get對象
        Get get = new Get(Bytes.toBytes("your_row_key")); // 使用你要查詢的行鍵

        // 執行Get操作
        Result result = table.get(get);

        // 統計數量
        int count = 1; // 因為我們使用了特定的行鍵，所以只統計到1條數據

        // 關閉資源
        table.close();
        connection.close();

        System.out.println("Total count: " + count);
    }
}

注意：在這兩個示例中，你需要將your_table_name替換為你的HBase表名，將your_row_key替換為你要查詢的行鍵。如果你需要統計整個表的數據數量，建議使用方法1（Scan操作）。