flatmap

def order_flatmap(row):
    result = [
        (row['o_addr_normal'],
         (row['order_id'], row['o_addr'], row['o_addr_normal'], row['o_lon'], row['o_lat'])),
        (row['d_addr_normal'],
         (row['order_id'], row['d_addr'], row['d_addr_normal'], row['d_unloaded_lon'], row['d_unloaded_lat']))
    ]
    return result