flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3646) Use Processing-Time Clock in Window Assigners/Triggers
Date Tue, 22 Mar 2016 11:04:25 GMT
Aljoscha Krettek created FLINK-3646:

             Summary: Use Processing-Time Clock in Window Assigners/Triggers
                 Key: FLINK-3646
                 URL: https://issues.apache.org/jira/browse/FLINK-3646
             Project: Flink
          Issue Type: Sub-task
          Components: Streaming
    Affects Versions: 1.0.0
            Reporter: Aljoscha Krettek

This is part of the effort to improve Window Triggers in Flink. We should replace all usage
of {{System.currentTimeMillis()}} by a provided clock implementation. This way we can use
a deterministic testing clock to verify the behavior of processing-time windowing components
in unit tests.

This requires the following changes:

- Change {{StreamTask}} to have a {{Clock}} (name is WIP). By default this clock will use
{{System.currentTimeMillis()}}. The clock must also provide an interface to register processing-time
triggers, this is currently handled directly by {{StreamTask}} but must now also be handled
by an external Clock
- Change API of {{WindowAssigner}} to take a context object that allows it to query the current
processing time. This can be an abstract class {{AssignerContext}} with a single method {{long
- Add a method {{long currentProcessingTime()}} in {{TriggerContext}}, change {{TriggerContext}}
to use the clock methods provided by {{StreamTask}} and forwarded by {{WindowOperator}}
- Change processing-time triggers to use the new methods
- Change {{WindowOperator}} to support these changes

This message was sent by Atlassian JIRA

View raw message