如何组合两个DStreams(pyspark)？

from pyspark import SparkContext
from pyspark.streaming import StreamingContext

sc = SparkContext(appName="DStreamExample")
ssc = StreamingContext(sc, batchDuration=1)  # 设置批处理间隔时间，单位为秒

inputStream1 = ssc.socketTextStream("localhost", 9999)  # 第一个输入DStream
inputStream2 = ssc.socketTextStream("localhost", 8888)  # 第二个输入DStream

combinedStream = inputStream1.union(inputStream2)

combinedStream.foreachRDD(lambda rdd: rdd.foreach(print))

ssc.start()
ssc.awaitTermination()