У меня есть следующий код: -
case class event(id: String, date: String)
object test {
def main(args: Array[String]) {
var collection = null
if(some_condition){
val a = some_value
val b = value2
val value3 = some_function_calculation_from other_class
val c = value3
val d = value4
collection = sc.parallelize(Seq(event(a,b),event(c,d)))
} else {
collection = sc.parallelize(Seq(event(e,f),event(g,h)))
}
collection.saveToCassandra("db", "table", SomeColumns("id", "date"))
}
}
Я хочу, чтобы мой объект коллекции был сохранен в cassandra со значениями seq события (a, b) и события (c, d), и когда, если условие не выполняется, это должно быть событие (e, f) и событие (g, h) но это идет как ноль. Где я ошибаюсь?
Примечание. Он отлично работает, когда нет блока if, что означает инициализацию всех определений коллекции в одной области.
Спасибо,
RDD[event]
из условияif
иelse
04.04.2018