Kostas Kloudas created FLINK-4494:
-------------------------------------
Summary: Expose the TimeServiceProvider from the Task to each
Operator.
Key: FLINK-4494
URL: https://issues.apache.org/jira/browse/FLINK-4494
Project: Flink
Issue Type: Bug
Reporter: Kostas Kloudas
This change aims at simplifying the {{StreamTask}} class by exposing directly
the {{TimeServiceProvider}} to the operators being executed.
This implies removing the {{registerTimer()}} and
{{getCurrentProcessingTime()}} methods from the {{StreamTask}}. Now, to
register a timer and query the time, each operator will be able to get the
{{TimeServiceProvider}} and call the corresponding methods directly on it.
In addition, this will simplify many of the tests which now implement their own
time providers.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
