code: def transformWith(self, func, other, keepSerializer=False):
          
          if func.__code__.co_argcount == 2:
              two_arg_func = func
              func = lambda _, rdd_a, rdd_b: two_arg_func(rdd_a, rdd_b)
  
          return TransformedWithDStream(self, func, other)
docs: Return a new DStream where each RDD is transformed by ``f``.
  
          :param f: transformation function
          :rtype: DStream
  
          The transformation function can have arguments ``(time, rdd_a, rdd_b)``
          or ``(rdd_a, rdd_b)``.