0
我需要讀取cassandra blob
類型的火花與spark-cassandra-connector並比較兩個基於blob字段的數據集。從卡桑德拉讀取blob類型火花與卡桑德拉連接器
作爲例如下面的代碼顯示了我的意思是:
// Cassandra Table
CREATE TABLE keyspace.test (
id bigint,
info blob,
PRIMARY KEY (id)
)
case class Test(
id: Long,
info: java.nio.ByteBuffer
)
session.read
.format("org.apache.spark.sql.cassandra")
.options(Map(
"table" -> tableName,
"keyspace" -> keySpaceName,
"cluster" -> clusterName
)).load().map(i => Test(i.getLong(0), i.get???(1)))
我需要的方法,而不是i.get???(1)
閱讀BLOB作爲字節緩衝區。我試過row.getAs[Array[Byte]](i)
,但它不滿足我的需要,因爲無法比較兩個對象。