У меня есть класс модели 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_tag