flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aditivin <...@git.apache.org>
Subject [GitHub] flink issue #2333: [FLINK-4282] [streaming] Add Offset Parameter to WindowAs...
Date Fri, 05 Aug 2016 04:54:37 GMT
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message