请问pySpark中怎么序列化一个对象集合为RDD？

Question

请问pySpark中怎么序列化一个对象集合为RDD？

例如: 这种最简单的操作
class test :

data = 1
def __init__(self):
    self.property=0

def test2(self):
    print('hello')

if name == '__main__':

p1 = test()
p2 = test()
a = [p1,p2]
sc = SparkContext('local[2]', 'test' )
rdd = sc.parallelize(a)
rdd.map(lambda x : x.property ).collect()
sc.stop()