Thank you for the reply. It's very helpful.
Best
Yan
On Tue, Oct 10, 2017 at 7:57 AM, Aljoscha Krettek
wrote:
> Hi,
>
> Yes, using a TwoInputStreamOperator (or even better, a CoProcessFunction,
> because TwoInputStreamOperator is a low-level interface that might change
> in the future) is the r
Hi,
Yes, using a TwoInputStreamOperator (or even better, a CoProcessFunction,
because TwoInputStreamOperator is a low-level interface that might change in
the future) is the recommended way for implementing a stream-stream join,
currently.
As you already guessed, you need a policy for cleanup
