Flink help / pairing

2019-09-17 Thread Benjamin Wootton
I am currently building a system based on Flink and could use some ongoing help. Is there any expert who would be free for some remote pairing? Happy to pay for time of course! Thanks Ben

Joining Pojos

2019-09-16 Thread Benjamin Wootton
Hi All I'm new to Flink. I am having a lot of success but I'm struggling with Windowed joins over Pojos. In a toy example I am trying to respond to flight delay events and pull some fields from flight details: flightDelaysStream .map(new FlightDelaysMapper()) .join(flightDetailsStream) * .wher