如何使用spark将scala对象存储到cassandra表中

wswtfjt7  于 2021-06-15  发布在  Cassandra
关注(0)|答案(1)|浏览(494)

我有一个scala模型类,我想将其对象存储到cassandra表中。cassandra和scala类变量声明的列名顺序不匹配。
在cassandra表中还有一个额外的列,这在scala类变量列表中是不存在的 (tr_tag Text) 但我做不到。
未插入数据。请帮我解决这个问题。
模型scala类:

class THData() extends Serializable{
     var s_id: java.lang.Long = null
     var a_id: String = null
     var s_typ: String= null
     var s_dt: java.util.Date= null
     var t_s_id: String= null
     var a_s_no: String= null
     var avg_sp: java.lang.Float = null
}

将对象插入cassandra的方法:

def insert(data: THData) {
     var em=sc.parallelize(Seq(data))
     em.saveToCassandra("ap", "t_s_data")
}

具有如下列名的cassndra表:
sid、aid、styp、sdt、tsid、asno、avgsp、tr\ U标签

vc9ivgsu

vc9ivgsu1#

我认为您应该修改文档中描述的列名:

相关问题