我有一个Kafka流进来一些输入主题。这是我为接受Kafka流而写的代码。

conf = SparkConf().setAppName(appname) 
sc = SparkContext(conf=conf) 
ssc = StreamingContext(sc) 
kvs = KafkaUtils.createDirectStream(ssc, topics,\ 
            {"metadata.broker.list": brokers})

然后我创建两个原始流的键和值的数据流。

keys = kvs.map(lambda x: x[0].split(" ")) 
values = kvs.map(lambda x: x[1].split(" "))

然后我在值dstream中执行一些计算。例如，

val = values.flatMap(lambda x: x*2)

现在，我需要将keys和valdstream组合起来，并以kafka流的形式返回结果。
如何将val组合到相应的键？