allowed lateness on windowed join?

[Saiph Kappa]

Hi all,

Is it possible to specify  allowed lateness for a window join like the
following one:

val tweetsAndWarning =
warningsPerStock.join(tweetsPerStock).where(_.symbol).equalTo(_.symbol)
    .window(SlidingEventTimeWindows.of(Time.of(windowDurationSec,
TimeUnit.SECONDS), Time.of(windowDurationSec,
      TimeUnit.SECONDS)))
  .apply((c1, c2) => (c1.count, c2.count))


I think it is related with these:
https://cwiki.apache.org/confluence/display/FLINK/Streaming+Window+Join+Rework
https://issues.apache.org/jira/browse/FLINK-3109


Thanks!