CoGroupedDStream similar to CoGroupedRDD

[Akhil Das]

Hi,

I have an ArrayList of RDDs (*RDD<Tuple2<Object, Tuple>>*) and I'm able to
create a CoGroupedRDD like:

CoGroupedRDD<Object> coGroupedRDD = new CoGroupedRDD<Object>(
>                 (Seq<RDD<? extends Product2<Object,
> ?>>>)(Object)(JavaConversions.asScalaBuffer(*rddPairs*).toSeq()),
>                 new HashPartitioner(parallelism));


Here *rddPairs* is my ArrayList which holds the RDDs.

Similarly, if i want to do the same with DStreams how do i achieve it? I
don't see any CoGroupedDStream but i found the cogroup() method inside the
PairDStreamFunctions.














Thanks
Best Regards