データフレームの各行には CSV コンテンツがあります。
各行を別の特定のテーブルに保存するのに苦労しています。
これを達成するには foreach または UDF を使用する必要があると思いますが、これは単に機能していません。
私が見つけたすべてのコンテンツは、 foreachs または .collect() を使用したコード内の単純な印刷のようなものでした (これは実際には使用したくありません)。
再分割の方法も見つけましたが、各行の移動先を選択することはできません。
rows = df.count()
df.repartition(rows).write.csv('save-dir')
簡単で実用的な例を教えてください。