ブロードキャスト 'オブジェクトには属性' destroy 'はありませんか？

Question

私のpyspark scirptコードで、私はBroadcast変数を宣言します。最後に、私はこの変数をDestoryは、このような

Blockquote AttributeError: 'Broadcast' object has no attribute 'destroy'

私のコードを取得したい：

br = sc.broadcast(my_value) 
rdd.map(__my_map_function) # __my_map_function() used br variable 
br.destroy() 

マイスパークのバージョンは1.6.1で、私はクラスの放送が破壊持って知っています（）しかし、なぜこのコードはこの例外をスローしますか？ありがとう。

Answer 1

destroyメソッドは、spark-2.xより前のpysparkでは利用できませんでした。

疑問がある場合はthe sourcesを確認できます。