Stream Aggregation $[$Rebala

We have a stream of hotel page views, $w$

a user $($maybe logged in to

Booking.com$)$

Every message is recorded with the follo

$\{$

hotel$\_$id: Long,

hotel$\_$area$\_$code: String,

unique$\_$user$\_$id: String,

is$\_$user$\_$logged$\_$in: Boolean

$\}$

We want you to create a new stream, which re

with the highest number of views by logged$-$in

If multiple hotels have the same number of hig

return one of them. Also, note that a hotel can

In the process you can also define some extra

primitives. As an example, if the initial input stre