happyfan428

def findItemPairs(user_id, items_with_rating): list = [] for item1,item2 in combinations(items_with_rating,2): list.append(((item1[0],item2[0]),(item1[1],item2[1]))) return list pairwise_items = user_item_pairs.filter( lambda p: len(p[1]) > 1).flatMap( lambda p: findItemPairs(p[0], p[1])).groupByKey()