Return-Path: <commits-return-10196-archive-asf-public=cust-asf.ponee.io@beam.incubator.apache.org>
X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io
Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io
Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183])
	by cust-asf2.ponee.io (Postfix) with ESMTP id 1CAD3200B92
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Wed, 28 Sep 2016 11:55:56 +0200 (CEST)
Received: by cust-asf.ponee.io (Postfix)
	id 1B643160AD4; Wed, 28 Sep 2016 09:55:56 +0000 (UTC)
Delivered-To: archive-asf-public@cust-asf.ponee.io
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by cust-asf.ponee.io (Postfix) with SMTP id 65985160AB4
	for <archive-asf-public@cust-asf.ponee.io>; Wed, 28 Sep 2016 11:55:55 +0200 (CEST)
Received: (qmail 924 invoked by uid 500); 28 Sep 2016 09:55:54 -0000
Mailing-List: contact commits-help@beam.incubator.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:commits-help@beam.incubator.apache.org>
List-Unsubscribe: <mailto:commits-unsubscribe@beam.incubator.apache.org>
List-Post: <mailto:commits@beam.incubator.apache.org>
List-Id: <commits.beam.incubator.apache.org>
Reply-To: dev@beam.incubator.apache.org
Delivered-To: mailing list commits@beam.incubator.apache.org
Received: (qmail 914 invoked by uid 99); 28 Sep 2016 09:55:54 -0000
Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 28 Sep 2016 09:55:54 +0000
Received: from localhost (localhost [127.0.0.1])
	by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 1FA36CA285
	for <commits@beam.apache.org>; Wed, 28 Sep 2016 09:55:54 +0000 (UTC)
X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: -5.144
X-Spam-Level: 
X-Spam-Status: No, score=-5.144 tagged_above=-999 required=6.31
	tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5,
	RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01,
	RP_MATCHES_RCVD=-1.124] autolearn=disabled
Received: from mx2-lw-eu.apache.org ([10.40.0.8])
	by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024)
	with ESMTP id d2Vwpx-IKdaF for <commits@beam.apache.org>;
	Wed, 28 Sep 2016 09:55:52 +0000 (UTC)
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with SMTP id 876495FB5A
	for <commits@beam.incubator.apache.org>; Wed, 28 Sep 2016 09:55:51 +0000 (UTC)
Received: (qmail 93303 invoked by uid 99); 28 Sep 2016 09:55:32 -0000
Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 28 Sep 2016 09:55:32 +0000
Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33)
	id C749DE0061; Wed, 28 Sep 2016 09:55:32 +0000 (UTC)
From: aljoscha <git@git.apache.org>
To: commits@beam.incubator.apache.org
Reply-To: commits@beam.incubator.apache.org
Message-ID: <git-pr-1021-incubator-beam@git.apache.org>
Subject: [GitHub] incubator-beam pull request #1021: [BEAM-615] Add Support for Processing-Tim...
Content-Type: text/plain
Date: Wed, 28 Sep 2016 09:55:32 +0000 (UTC)
archived-at: Wed, 28 Sep 2016 09:55:56 -0000

GitHub user aljoscha opened a pull request:

    https://github.com/apache/incubator-beam/pull/1021

    [BEAM-615] Add Support for Processing-Time Timers in FlinkRunner

    This adds support for processing-time timers that are checkpointed.
    
    There are no tests for this yet but I ran this minimal example successfully:
    ```java
    pipeline
        .apply(CountingInput.unbounded().withRate(5, Duration.standardSeconds(1)))
        .apply(
            Window.<Long>into(new GlobalWindows())
                .withAllowedLateness(Duration.ZERO)
                .triggering(Repeatedly.forever(AfterProcessingTime.pastFirstElementInPane().plusDelayOf(Duration.standardSeconds(1))))
                .discardingFiredPanes())
        .apply(ParDo.of(new DoFn<Long, KV<String, Long>>() {
          @DoFn.ProcessElement
          public void proc(ProcessContext ctx) {
            ctx.output(KV.of("key", ctx.element()));
          }
        }))
        .apply(Combine.<String, Long>perKey(new SerializableFunction<Iterable<Long>, Long>() {
          @Override
          public Long apply(Iterable<Long> input) {
            System.out.println("GOT: " + Joiner.on(',').join(input));
            return 0L;
          }
        }));
    
    pipeline.run();
    ```
    
    R: @mxm for review

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/aljoscha/incubator-beam flink-processing-time-timers

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/incubator-beam/pull/1021.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #1021
    
----
commit a1cc636c25561d6300a9a39c3a79d1dfd0eba37f
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Date:   2016-09-28T09:49:54Z

    [BEAM-615] Add Support for Processing-Time Timers in FlinkRunner Window Operator

----


---
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.
---