0
Spark Cassandra Connectorを使用して、私はEXIFTS IF EXISTSを使用したい場合があります。テーブルに存在しない場合は無視してください。Spark Cassandraコネクタ更新のみ存在する場合
Cassandra documentationでは、この条件がCassandra 2.0.7以降では、IFまたはIF EXISTSを使用して条件付きで列を更新できます。
IFは、指定された行が存在しない場合は動作が行われないことを確実にするためにコマンドするために存在する追加：
UPDATE cycling.cyclist_id SET年齢= 28 WHERE LASTNAME = 'WELTEN' とFIRSTNAME = 'ブラム '存在する場合;
しかし、これがSpark Cassandra Connectorで実行できるかどうかは不明です。誰でもこれがどうやってできるのか知っていますか？
で回答？あなたはそれを試しましたか？コネクターはCQL照会を実行するので、構文的に正しい照会を解釈できるはずです。 – eliasah
私の問題は、2つの大きなデータセットがあります。そこでは、データは結合によって引っ張られなければならず、2つのデータセットを結合しないようにしたいのです。 私が試している回避策は、一時テーブルを作成し、最初にフィルタリングされたデータセットを挿入し、結合するのを避けてCassandra機能を利用できる場合にのみ同じキーで更新することです。 私はAndrew Millsからの情報を持っています 今のところできることではないが、それは未解決の問題です。 https://datastax-oss.atlassian.net/browse/SPARKC-386 P.S.私は回避策を持っていますが、spark-cassandraを使って最適化できるかどうかを確認したい場合 –
あなたの質問にはどのような関係がありますか？あなたは更新を実行したいので... – eliasah