Setting SlotSharingGroups for Joins and Sorting Keyed Streams

[Dimitris Palyvos <dm...@gmail.com>]

Hello,

I have two unrelated questions regarding the Flink API. Both of these are
connected to some proof-of-concepts and will not be deployed in an actual
production environment, so even less-than-ideal suggestions are welcome!

First, maybe this is a silly question, but is it possible to set the
slotSharingGroup for a join? I cannot seem to be able to set this using the
standard join API:
stream.join(..).where(...).equalTo(...).window(...).apply(...)

Second, is there a good way to sort a keyed stream before pushing it
through an aggregate? I am thinking of something like what is described
here (I know this does not actually exist):
https://cwiki.apache.org/confluence/display/FLINK/Time+and+Order+in+Streams

I was thinking of something like stream.keyBy(...).flatMap(new
MyBufferingAndSortingOp()).window(..) but the flatMap returns a
SingleOutputStreamOperator so this does not work. Is there any other way to
sort the tuples in a window except doing it inside the
AggregateFunction/ProcessWindowFunction?

Thank you in advance!

Kind regards,
Dimitris Palyvos