Pythonセットを使用したAggregateBykey

Question

私は、aggregateByKeyについて説明する以下のスカラーの例を見つけました。 スカラ例：上記のScalaのコードの

val pairs=sc.parallelize(Array(("a",3),("a",1),("b",7),("a",5))) 
import scala.collection.mutable.HashSet 
//the initial value is a void Set. Adding an element to a set is the first 
//_+_ Join two sets is the _++_ 
val sets = pairs.aggregateByKey(new HashSet[Int])(_+_, _++_) 
sets.collect 

出力は次のとおりです。私が間違っているかわからない

pair = sc.parallelize([("a",3),("a",1),("b",7),("a",5)]) 
sets=pair.aggregateByKey((set()),(lambda x,y:x.add(y)),(lambda x,y:x|y)) 
sets.collect() 

：

res5: Array[(String, scala.collection.mutable.HashSet[Int])] =Array((b,Set(7)), (a,Set(1, 5, 3))) 

私はPythonで上記Scalaのコードを書き直しました。 Pythonのコードは、次のエラーメッセージを返します。

AttributeError: 'NoneType' object has no attribute 'add' 

Answer 1

機能addは、（それが更新されたセットを返さない）のセットを更新し、NoneTypeを返します。このNoneTypeは、関数の次の反復に渡されます。したがって、エラーが発生します。

def my_add(x, y): 
    x.add(y) 
    return x 
sets = pair.aggregateByKey(set(), my_add, lambda x, y: x|y) 
sets.collect() 

    [('b', {7}), ('a', {1, 3, 5})]