Я хочу присоединиться к таблице Cassandra слева и попробовать leftJoinWithCassandraTable (ожидаем получить нажатие). Я хочу сделать что-то вроде:
some_dataframe
.rdd
.leftJoinWithCassandraTable("ks", "some_table")
.on(SomeColumns("col1", "col2"))
//.add new col here with (case when right_table.col1 is null then 0 else 1 end.
//.select some col from left table, and some col from right table
//.saveToCassandra
, но я не могу заставить работать части комментария. Кто-нибудь может помочь в этом?
Спасибо