2016-04-06 7 views
0

spark RDDを使用してcassandraにアップデート/アップをしたいのですが、どうすればそれが可能か分かりますか?spark cassandra update/upsert

更新従業員のセットの給料=「」EMPID =「」

答えて

1

ちょうど

+0

感謝を更新/挿入するように列を持つrdd.saveToCassandra()を使用し、私は現在saveToCassandra()挿入のために私を使用しています を使用して検索と更新を行っています。rdd.repartition(24).map どのようにキーを持たないwhere条件を実行するのですか? – ashK

+0

私は今、私たちは主キーとして複数の列を作成し、次にsaveToCassandra()を行う必要があることを理解していると思います。 – ashK

関連する問題