dgadiraju
1/4/2018 - 11:05 AM

OrderItemsMR.py

# Get order reveue for order_id 2
orderItems = open("/data/retail_db/order_items/part-00000").read().splitlines()
orderItemsFiltered = filter(lambda p: int(p.split(",")[1]) == 2, orderItems)
orderItemsRevenue = map(lambda p: float(p.split(",")[4]), orderItemsFiltered)
import functools as ft
orderRevenue = ft.reduce(lambda x, y: x + y, orderItemsRevenue)
print(orderRevenue)

# Get min order item revenue for order_id 2
orderItems = open("/data/retail_db/order_items/part-00000").read().splitlines()
orderItemsFiltered = filter(lambda p: int(p.split(",")[1]) == 2, orderItems)
orderItemsRevenue = map(lambda p: float(p.split(",")[4]), orderItemsFiltered)
import functools as ft
orderMinRevenue = ft.reduce(lambda x, y: x if(x <= y) else y, orderItemsRevenue)
print(orderMinRevenue)