def result(y):
return y


d_stream = input_stream.map(lambda x : mainReduce(x)).map(lambda q: q)

rdd = d_stream.foreach(result)