RDD has a method keyBy[K](f: T=>K) that acts as an alias for map(x =>
(f(x), x)) and is useful for generating pair RDDs.  Is there a reason this
method doesn't exist on DStream?  It's a fairly heavily used method and
allows clearer code than the more verbose map.

Reply via email to