flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Saiph Kappa <saiph.ka...@gmail.com>
Subject allowed lateness on windowed join?
Date Mon, 30 Jan 2017 16:38:27 GMT
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!

Mime
View raw message