私はテーブルとしてPySparkデータフレームを保存しようとしているテーブルに挿入するか、一つのコマンドから

Question

をテーブルを作成します。

myDf.write.saveAsTable("myDf") 

しかし、私は二回のコードを実行した場合、私は

u'Table `myDf` already exists.;' 

を取得した場合私はこのようにそれを保存します。

myDf.write.inserInto("myDf") 

私は、このエラーが発生します。u'Table not found: myDf;'

テーブルを保存すると、コードを何回実行してもエラーは発生しません。

Answer 1

テーブルが存在するかどうかを確認するためにif conditionを入れないのはなぜですか？

場合によっては、registerDataFrameAsTable(df, tableName)を使用すると、指定されたDataFrameをカタログの一時テーブルとして登録することができます。これはSQLContextのインスタンスの存続期間中のみ存在します。

詳細については、documentationを参照してください。 これを使用すると、コードを何回でも実行できるようになり、エラーは発生しなくなります。

Answer 2

myDf.write.mode("overwrite").saveAsTable("myDf") 

それは（私にすべての時間に発生）シナリオが、ここであなたがもう少し必要がある場合でrefである「ああ、私はそれはとても簡単です知っている希望」明らかに思えます。