code: def transform(self, func):
          
          if func.__code__.co_argcount == 1:
              oldfunc = func
              func = lambda t, rdd: oldfunc(rdd)
          assert func.__code__.co_argcount == 2, "func should take one or two arguments"
          return TransformedDStream(self, func)
docs: Return a new DStream in which each RDD is generated by applying a function
          on each RDD of this DStream.
  
          `func` can have one argument of `rdd`, or have two arguments of
          (`time`, `rdd`)