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.