From 1f5595c19fe024d5eac6a56d639e9409541e3820 Mon Sep 17 00:00:00 2001 From: Aaron Staple Date: Mon, 8 Sep 2014 10:29:47 -0700 Subject: [PATCH] Fix python style --- python/pyspark/join.py | 1 + 1 file changed, 1 insertion(+) diff --git a/python/pyspark/join.py b/python/pyspark/join.py index 34565ad312049..b4a844713745a 100644 --- a/python/pyspark/join.py +++ b/python/pyspark/join.py @@ -95,6 +95,7 @@ def dispatch(seq): return [(v, w) for v in vbuf for w in wbuf] return _do_python_join(rdd, other, numPartitions, dispatch) + def python_cogroup(rdds, numPartitions): def make_mapper(i): return lambda (k, v): (k, (i, v))