Mailing-List: contact issues-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
Date: Wed, 1 Jul 2015 15:08:05 +0000 (UTC)
From: "ASF GitHub Bot (JIRA)" <jira@apache.org>
To: issues@flink.apache.org
Message-ID: <JIRA.12826909.1430742232000.72356.1435763285453@Atlassian.JIRA>
In-Reply-To: <JIRA.12826909.1430742232000@Atlassian.JIRA>
References: <JIRA.12826909.1430742232000@Atlassian.JIRA>
 <JIRA.12826909.1430742232208@arcas>
Subject: [jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


    [ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610428#comment-14610428 ] 

ASF GitHub Bot commented on FLINK-1967:
---------------------------------------

Github user rmetzger commented on a diff in the pull request:

    https://github.com/apache/flink/pull/879#discussion_r33687769
  
    --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
    @@ -141,6 +144,25 @@ public boolean isClosureCleanerEnabled() {
     	}
     
     	/**
    +	 * Sets the interval of the automatic watermark emission. Watermaks are used throughout
    +	 * the streaming system to keep track of the progress of time. They are used, for example,
    +	 * for time based windowing.
    +	 */
    +	public ExecutionConfig setAutoWatermarkInterval(Duration interval) {
    --- End diff --
    
    Documentation? http://ci.apache.org/projects/flink/flink-docs-master/apis/programming_guide.html#execution-configuration


> Introduce (Event)time in Streaming
> ----------------------------------
>
>                 Key: FLINK-1967
>                 URL: https://issues.apache.org/jira/browse/FLINK-1967
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: Aljoscha Krettek
>            Assignee: Aljoscha Krettek
>
> This requires introducing a timestamp in streaming record and a change in the sources to add timestamps to records. This will also introduce punctuations (or low watermarks) to allow windows to work correctly on unordered, timestamped input data. In the process of this, the windowing subsystem also needs to be adapted to use the punctuations. Furthermore, all operators need to be made aware of punctuations and correctly forward them. Then, a new operator must be introduced to to allow modification of timestamps.


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)