class pyspark.MarshalSerializer

class pyspark.PickleSerializer

--------------------------------------serializing.py-------------------------------------
from pyspark.context import SparkContext
from pyspark.serializers import MarshalSerializer
sc = SparkContext("local", "serialization app", serializer = MarshalSerializer())
print(sc.parallelize(list(range(1000))).map(lambda x: 2 * x).take(10))
sc.stop()
--------------------------------------serializing.py-------------------------------------

$SPARK_HOME/bin/spark-submit serializing.py

[0, 2, 4, 6, 8, 10, 12, 14, 16, 18]