code: def python_join(rdd, other, numPartitions):
      def dispatch(seq):
          vbuf, wbuf = [], []
          for n, v in seq:
              if n == 1:
                  vbuf.append(v)
              elif n == 2:
                  wbuf.append(v)
          return ((v, w) for v in vbuf for w in wbuf)
  
      return _do_python_join(rdd, other, numPartitions, dispatch)
  
file_path: spark/python/pyspark/join.py
imports: from functools import reduce
  from pyspark.resultiterable import ResultIterable
label_desc: Use image node_id 2 for calling a global function with example usage: python_join(rdd, other, numPartitions) and returns: _do_python_join, unknown