flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vladislav Pernin <vladislav.per...@gmail.com>
Subject TumblingEventTimeWindows with negative offset / Wrong documentation
Date Wed, 29 Mar 2017 14:57:33 GMT
Hi,

The documentation mentions the possibility to use a negative offset with
a TumblingEventTimeWindows :

// daily tumbling event-time windows offset by -8 hours.input
    .keyBy(<key selector>)
    .window(TumblingEventTimeWindows.of(Time.days(1), Time.hours(-8)))
    .<windowed transformation>(<window function>);


But the code will throw an IllegalArgumentException :

if (offset < 0 || offset >= size) {
   throw new IllegalArgumentException("TumblingEventTimeWindows
parameters must satisfy 0 <= offset < size");
}


Regards,
Vladislav

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message