如何将Spark Streaming DStream转换为RDD，以便在Spark Context中使用而不是在Streaming Context中使用？使用Python .
这是我得到的错误：AttributeError：'TransformedDStream'对象没有属性'foreach'
def result(y):
return y
d_stream = input_stream.map(lambda x : mainReduce(x)).map(lambda q: q)
rdd = d_stream.foreach(result)