With this exercise you will connect two streams: (1) a stream of TaxiRide events and (2) a query stream on which you can type queries (a query being an integer n on a line by itself). The expected output is all rides which, at the time the query is processed, started at least n minutes ago (in event time) and haven’t yet ended.

On MacOS and Linux you can start the broadcast query stream via

nc -lk 9999

and on Windows you can install ncat from https://nmap.org/ncat/ and then use

ncat -lk 9999

Getting Started

Exercise Class


Extra Credit

There’s no integration test for this exercise. How might you go about testing your solution?

Reference Solution

Reference solutions are available at GitHub: