如何将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)