Re: How to combine two DStreams(pyspark)?

For Example, > *>>> val = values.flatMap(lambda x: x*2)* > > Now, I need to combine the */keys/* and the */val/* *DStream* and return > the > result in the form of *Kafka* stream. > > How to combine val to the corressponding key? > > > > -- > View this mess

How to combine two DStreams(pyspark)?

rform some computation in the values DStream. For Example, *>>> val = values.flatMap(lambda x: x*2)* Now, I need to combine the */keys/* and the */val/* *DStream* and return the result in the form of *Kafka* stream. How to combine val to the corressponding key? -- View this message in cont