hadoop - 使用MapReduce在指定程度内结识 friend

您知道如何使用MapReduce范例实现此算法吗？

def getFriends(self, degree):
    friendList = []
    self._getFriends(degree, friendList)
    return friendList

def _getFriends(self, degree, friendList):
    friendList.append(self)
    if degree:
        for friend in self.friends:
            friend._getFriends(degree-1, friendList)

假设我们有以下双向友谊:

(1,2)，(1,3)，(1,4)，(4,5)，(4,6)，(5,7)，(5,8)

例如，如何获得用户1的1、2和3度连接？答案必须是1-> 2、3、4、5、7、8

谢谢

最佳答案

也许您可以使用支持类似sql的查询的 hive !