flatmap
2021-12-08 本文已影响0人
hehehehe
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
