join - Apache Spark SQL で更新を実行する方法

Question

JavaSchemaRDDいくつかの条件を設定して、いくつかの新しい値でa を更新する必要がありWHEREます。

これは、Spark SQL に変換したい SQL クエリです。

UPDATE t1
  SET t1.column1 = '0', t1.column2 = 1, t1.column3 = 1    
  FROM TABLE1 t1
  INNER JOIN TABLE2 t2 ON t1.id_column = t2.id_column     
  WHERE (t2.column1 = 'A') AND (t2.column2 > 0)