問題タブ [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.

0 投票する
0 に答える
101 参照

python - PicklingError: オブジェクトをシリアル化できませんでした: 為替レート API を pyspark データフレームに呼び出すとき

私はデータブリックとpysparkの初心者です。現在、3列を含むpysparkデータフレームがあります:

  • 日にち
  • 通貨

金額列を EUR に換算し、その日の為替レートで計算したいと考えています。そのために、為替レート API を使用して、日付と通貨をパラメーターとして取得し、為替レートを調べています。

最初に、為替レートを見つけるために API 呼び出しを行う関数を定義しました。

ここに私のコードがあります:

次に、データフレーム内でこの関数を呼び出す UDF を定義しました。

この部分を実行しようとすると、絶対に理解できない酸洗エラーが発生します...

この問題を解決するのを手伝ってくれませんか?

どうもありがとう