Github user aditivin commented on the issue:
https://github.com/apache/flink/pull/2333
Hi,
Only the relevant changes are now visible. Pasting the details from the
previous pull request (#2331) here:
Added offset parameter for the following processing time window assigners:
ProcessingTimeSessionWindows
SlidingProcessingTimeWindows
TumblingProcessingTimeWindows
The offset is an optional parameter that can be added while creating these
classes, and it can be supplied as a long value or a TimeZone.
Test cases for the change are present in WindowAssignerOffsetTest. There
are tests for positive, negative and TimeZone offsets for each of the classes.
All Travis CI jobs passed.
I haven't done it for the event time window assigners yet - I can add that
if this is all right.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
