Skip to content

Commit

Permalink
implement map-side join in gpextras; phirl-improved; pagerank
Browse files Browse the repository at this point in the history
  • Loading branch information
wwcohen committed Oct 19, 2017
1 parent 3b051ca commit 2b091aa
Show file tree
Hide file tree
Showing 5 changed files with 10,106 additions and 2 deletions.
2 changes: 1 addition & 1 deletion gpextras.py
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ def logprogress(rowValue,rowIndex):


def MapsideJoin(jinForLargeView, jinForSmallView):
""" A map-side join using Augment
""" A map-side join implementation using Augment
"""
def smallViewLoader(view):
smallViewDict = {}
Expand Down
2 changes: 1 addition & 1 deletion guineapig.py
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,7 @@ def __str__(self):
class ReduceTo(object):
"""An object x that can be the argument of a reducingTo=x parameter in
a Group view. Basetype is a function f such that f() returns the
initial value of the accumuator, and 'by' is a function that
initial value of the accumulator, and 'by' is a function that
maps one accumulator and a single new value to the next accumulator.
"""
def __init__(self,baseType,by=lambda accum,val:accum+val):
Expand Down
Loading

0 comments on commit 2b091aa

Please sign in to comment.