POJO is available in KeySelector[1].
Could you provide more information about your problem? Version of Flink?
Error messages?
[1]
https://ci.apache.org/projects/flink/flink-docs-stable/dev/api_concepts.html#define-keys-using-key-selector-functions
*Best Regards,*
*Zhenghua Gao*
On Mon, Sep 16,
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
