如何在hbase中比较单元格值和字符串，并统计频率？

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.filter.CompareFilter;
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

public class HBaseComparisonExample {
    public static void main(String[] args) throws IOException {
        // 创建HBase配置对象
        Configuration conf = HBaseConfiguration.create();

        // 设置HBase集群的ZooKeeper地址
        conf.set("hbase.zookeeper.quorum", "localhost");

        // 创建HBase连接
        Connection connection = ConnectionFactory.createConnection(conf);

        // 获取HBase表的实例
        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_qualifier"));

        // 创建过滤器，比较单元格值和字符串
        CompareFilter.CompareOp compareOp = CompareFilter.CompareOp.EQUAL;
        SingleColumnValueFilter filter = new SingleColumnValueFilter(
                Bytes.toBytes("your_column_family"),
                Bytes.toBytes("your_column_qualifier"),
                compareOp,
                Bytes.toBytes("your_target_string")
        );

        // 设置过滤器
        scan.setFilter(filter);

        // 执行扫描操作
        ResultScanner scanner = table.getScanner(scan);

        // 统计频率的计数器
        int count = 0;

        // 遍历结果集
        for (Result result : scanner) {
            // 获取单元格的值
            byte[] valueBytes = result.getValue(Bytes.toBytes("your_column_family"), Bytes.toBytes("your_column_qualifier"));
            String value = Bytes.toString(valueBytes);

            // 比较单元格的值和目标字符串
            if (value.equals("your_target_string")) {
                count++;
            }
        }

        // 输出频率统计结果
        System.out.println("Frequency: " + count);

        // 关闭连接
        scanner.close();
        table.close();
        connection.close();
    }
}