...

The buffer will be checked whenever stream time is advanced. From then the record will be evicted and sent down to the next processor, the join node. The buffer will use an implementation of TimeOrderedKeyValueBuffer .

Setting the grace period will only be allowed for already materialized tables with a table history retention that is greater than the stream buffer's grace period. All other configurations will result in an Exception.

Compatibility, Deprecation, and Migration Plan

...