example recommendation workflow

example.py

event_clicks = get_clicks()  # reusable!
# [(user_id, guest_id, event_id),...]

event_clicks = collapse_to_person_event(event_clicks)   # reusable! testable!
# [(person_id, event_id),...]

person_to_their_events = event_clicks.reduceByKey(event_clicks)
# [(person_id, [event_id,...])...]

event_sets = person_to_their_events.values()
# [[event_id,...]]

event_to_events_cooccurrence = cooccurrence(event_sets)  # reusable! testable!
# [(event_id, [event_id,...])]

person_to_events_recommendations = multiply(person_to_their_events, event_to_events_cooccurrence)  # reusable! testable! also, naming is tricky
# [(person_id, {event_id:weight...})...]

event_to_persons_recommendations = transpose(person_to_events_recommendations)  # reusable! testable!
# [(event_id, {person_id:weight...}...]

recommended_events = event_to_persons_recommendations.keys()
# [event_id...]

put_recommended_events(recommended_events)  # reusable!
put_event_to_person_recommendations(event_to_persons_recommendations) # reusable!