You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@spark.apache.org by anshu shukla <an...@gmail.com> on 2015/07/09 03:51:43 UTC

Error while taking union

Hi  all ,

I want to create union of 2 DStreams  , in one of them  *RDD is  created
 per  1 second* , other is having RDD generated by reduceByWindowandKey
 with   *duration set to 60 sec.* (slide duration also 60 sec .)

- Main idea is to  do some analysis for every minute data and emitting
union of input data (per sec.)  and   transformed data (per min.) .