如何使用spark-connector-api在where子句中设置blob列？

Question

我正在试图找出如何在where子句下设置blob列。知道吗？

例如，如果我将以下查询放在cqlsh中，它就可以工作

select * from hello where id=0xc1c1795a0b;

//id是cassandra中的blob列

我尝试了以下方法

JavaRDD<CassandraRow> cassandraRowsRDD = javaFunctions(sc).cassandraTable("test", "hello")
.select("range" )
.where("id=?", "0xc1c1795a0b");

这给了我一个类型转换器异常

我尝试了这个

JavaRDD<CassandraRow> cassandraRowsRDD = javaFunctions(sc).cassandraTable("test", "hello")
.select("range" )
.where("id=?", "0xc1c1795a0b".getBytes());

这没有给我任何错误，但它没有返回任何结果。我的 cqlsh 中的查询确实返回了一堆结果。所以我不确定在 where 子句中设置一个 blob。我正在使用Java。有什么想法吗？

Answer 1

使用这个。

import com.datastax.driver.core.utils.Bytes;

JavaRDD<CassandraRow> cassandraRowsRDD = javaFunctions(sc).cassandraTable("test", "hello")
.select("range" )
.where("id=?",Bytes.getArray(Bytes.fromHexString("0xc1c1795a0b")));