在bigtable cbt中使用列值进行搜索

import com.google.cloud.bigtable.hbase.BigtableConfiguration;
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;

public class BigtableSearchExample {
    public static void main(String[] args) throws Exception {
        // 连接Bigtable CBT
        Connection connection = BigtableConfiguration.connect("PROJECT_ID", "INSTANCE_ID");

        // 获取表对象
        Table table = connection.getTable(TableName.valueOf("TABLE_NAME"));

        // 创建过滤器
        SingleColumnValueFilter filter = new SingleColumnValueFilter(
                Bytes.toBytes("COLUMN_FAMILY"),
                Bytes.toBytes("COLUMN_QUALIFIER"),
                CompareFilter.CompareOp.EQUAL,
                Bytes.toBytes("COLUMN_VALUE")
        );

        // 执行搜索
        Scan scan = new Scan();
        scan.setFilter(filter);
        ResultScanner scanner = table.getScanner(scan);

        // 处理搜索结果
        for (Result result : scanner) {
            // 处理每一行数据
            for (Cell cell : result.listCells()) {
                // 处理每个单元格数据
                byte[] value = cell.getValueArray();
                // 处理列值
            }
        }

        // 关闭资源
        scanner.close();
        table.close();
        connection.close();
    }
}