soc.py

def main(sc, args):
   # ...
   # read input logs
   business_rdd = sc.textFile(path_finder('yelp', 'business')).map(parse_line)
   # ...
   # ...
   # apply logic
   eligible_biz_list_rdd = get_eligible_business_list_rdd(business_rdd)
   biz_id_to_locations_rdd = get_business_id_to_location(unique_biz_ids, business_rdd)
   # ...
   # ...
   # write output
   output_rdd.saveAstextFile(output_path)