問題タブ [delta-lake]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票する
3 に答える
804 参照

pyspark - データフレームの各行を別のデルタテーブルに書き込む/writeStreamする方法

データフレームの各行には CSV コンテンツがあります。

各行を別の特定のテーブルに保存するのに苦労しています。

これを達成するには foreach または UDF を使用する必要があると思いますが、これは単に機能していません。

私が見つけたすべてのコンテンツは、 foreachs または .collect() を使用したコード内の単純な印刷のようなものでした (これは実際には使用したくありません)。

再分割の方法も見つけましたが、各行の移動先を選択することはできません。

簡単で実用的な例を教えてください。