The PR for this has a question that I'd like some feedback on.
https://github.com/apache/flink/pull/5295

The issue is, in order to be able to pass a typed event to the session gap
extractor, the assigner needs to be generic. And if the assigner is
generic, then the triggers need to be generic.

And unfortunately, the two current triggers aren't generic, and I've need
to add exact copies of these triggers that do accept a type.

It's possible to remove all the typing (and therefore the two new
triggers), and use the current triggers, but that causes the extract method
in the SessionWindowTimeGapExtractor to accept Object, and anyone
implementing it will need to cast the event to their expected type.

I don't find making the end user cast from Object to be the most friendly
interface, especially when the type information is otherwise available, but
I'm also not happy to have created exact copies of the trigger classes
simply because they aren't currently generic.

Was a similar discussion had when the current Session Window Assigners were
implemented? They hard type the event to Object as well, which I found a
bit odd.

Thanks,
Dyana

Reply via email to