Found this transform fn in StreamingContext which takes in a DStream[_] and a function which acts on each of its RDDs Unfortunately I can't figure out how to transform my DStream[(String,Int)] into DStream[_]
/*** Create a new DStream in which each RDD is generated by applying a function on RDDs of the DStreams. */ def transform[T: ClassTag]( dstreams: Seq[DStream[_]], transformFunc: (Seq[RDD[_]], Time) => RDD[T] ): DStream[T] = { new TransformedDStream[T](dstreams, sparkContext.clean(transformFunc)) } -Adrian