3

RDD と cassandra テーブルで結合を作成しようとしていますが、同じキーに対して同じ名前ではありません (簡略化)。

case class User(id : String, name : String)

case class Home( address : String, user_id : String)

やりたい場合:

rdd[Home].joinWithCassandraTable("testspark","user").on(SomeColumns("id"))

結合が行われるフィールドの名前を正確に知るにはどうすればよいですか? そして、joinWithCassandraTable の後にすべての値を結合したいので、rdd を正しい ID だけにマップしたくありません。

4

2 に答える 2