問題タブ [scala-pickling]
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.
python - PicklingError: オブジェクトをシリアル化できませんでした: 為替レート API を pyspark データフレームに呼び出すとき
私はデータブリックとpysparkの初心者です。現在、3列を含むpysparkデータフレームがあります:
- 日にち
- 額
- 通貨
金額列を EUR に換算し、その日の為替レートで計算したいと考えています。そのために、為替レート API を使用して、日付と通貨をパラメーターとして取得し、為替レートを調べています。
最初に、為替レートを見つけるために API 呼び出しを行う関数を定義しました。
ここに私のコードがあります:
次に、データフレーム内でこの関数を呼び出す UDF を定義しました。
この部分を実行しようとすると、絶対に理解できない酸洗エラーが発生します...
この問題を解決するのを手伝ってくれませんか?
どうもありがとう