flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From florianschmidt1994 <...@git.apache.org>
Subject [GitHub] flink issue #5342: [FLINK-8479] Timebounded stream join
Date Mon, 29 Jan 2018 08:13:35 GMT
Github user florianschmidt1994 commented on the issue:

    @bowenli86 the document should now be be public for everyone to comment on. 
    Yes, it caches data on either side, and for each incoming element it looks up eligible
records from the other side, and joins and emits those if they fulfil the user criteria. Entries
get removed from the cache whenever they are too old to be joined, which is determined by
a combination of the current watermark and the time boundary defined by the user.


View raw message