Given two async streams -
Trip : {tripId, date, city}
Bill: {billId, tripId, date, amount}

Design a system to get real time aggregated view of following nature
City, TripCount, TotalAmount

Events in both streams can be out of sync or duplicate. But result needs to be accurate and realtime.