Skip to content

Commit

Permalink
Fix python style
Browse files Browse the repository at this point in the history
  • Loading branch information
staple committed Sep 8, 2014
1 parent 7ac0aa9 commit 1f5595c
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions python/pyspark/join.py
Original file line number Diff line number Diff line change
Expand Up @@ -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))
Expand Down

0 comments on commit 1f5595c

Please sign in to comment.