問題タブ [spark-csv]
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.
136 問題
0
投票する
1
に答える
6460
参照
scala - 入力ファイル名を分割し、spark データ フレーム列に特定の値を追加する方法
これは、sparkデータフレームにcsvファイルをロードする方法です
これは私の入力ファイル名の例です。
今、私はこのファイルを読み込んで、「。」で分割したいと考えています。演算子を選択してから、 CUS を DataPartition の代わりに新しい列として追加します。
UDF なしで実行できますか。
これが既存のデータフレームのスキーマです
提案された回答の後にコードを更新する