{"action":"created","issue":{"url":"https://api.github.com/repos/apache/incubator-beam/issues/1021","repository_url":"https://api.github.com/repos/apache/incubator-beam","labels_url":"https://api.github.com/repos/apache/incubator-beam/issues/1021/labels{/name}","comments_url":"https://api.github.com/repos/apache/incubator-beam/issues/1021/comments","events_url":"https://api.github.com/repos/apache/incubator-beam/issues/1021/events","html_url":"https://github.com/apache/incubator-beam/pull/1021","id":179728980,"number":1021,"title":"[BEAM-615] Add Support for Processing-Time Timers in FlinkRunner","user":{"login":"aljoscha","id":68551,"avatar_url":"https://avatars.githubusercontent.com/u/68551?v=3","gravatar_id":"","url":"https://api.github.com/users/aljoscha","html_url":"https://github.com/aljoscha","followers_url":"https://api.github.com/users/aljoscha/followers","following_url":"https://api.github.com/users/aljoscha/following{/other_user}","gists_url":"https://api.github.com/users/aljoscha/gists{/gist_id}","starred_url":"https://api.github.com/users/aljoscha/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/aljoscha/subscriptions","organizations_url":"https://api.github.com/users/aljoscha/orgs","repos_url":"https://api.github.com/users/aljoscha/repos","events_url":"https://api.github.com/users/aljoscha/events{/privacy}","received_events_url":"https://api.github.com/users/aljoscha/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2016-09-28T09:55:29Z","updated_at":"2016-09-28T16:48:39Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/incubator-beam/pulls/1021","html_url":"https://github.com/apache/incubator-beam/pull/1021","diff_url":"https://github.com/apache/incubator-beam/pull/1021.diff","patch_url":"https://github.com/apache/incubator-beam/pull/1021.patch"},"body":"This adds support for processing-time timers that are checkpointed.\r\n\r\nThere are no tests for this yet but I ran this minimal example successfully:\r\n```java\r\npipeline\r\n    .apply(CountingInput.unbounded().withRate(5, Duration.standardSeconds(1)))\r\n    .apply(\r\n        Window.<Long>into(new GlobalWindows())\r\n            .withAllowedLateness(Duration.ZERO)\r\n            .triggering(Repeatedly.forever(AfterProcessingTime.pastFirstElementInPane().plusDelayOf(Duration.standardSeconds(1))))\r\n            .discardingFiredPanes())\r\n    .apply(ParDo.of(new DoFn<Long, KV<String, Long>>() {\r\n      @DoFn.ProcessElement\r\n      public void proc(ProcessContext ctx) {\r\n        ctx.output(KV.of(\"key\", ctx.element()));\r\n      }\r\n    }))\r\n    .apply(Combine.<String, Long>perKey(new SerializableFunction<Iterable<Long>, Long>() {\r\n      @Override\r\n      public Long apply(Iterable<Long> input) {\r\n        System.out.println(\"GOT: \" + Joiner.on(',').join(input));\r\n        return 0L;\r\n      }\r\n    }));\r\n\r\npipeline.run();\r\n```\r\n\r\nR: @mxm for review"},"comment":{"url":"https://api.github.com/repos/apache/incubator-beam/issues/comments/250226312","html_url":"https://github.com/apache/incubator-beam/pull/1021#issuecomment-250226312","issue_url":"https://api.github.com/repos/apache/incubator-beam/issues/1021","id":250226312,"user":{"login":"mxm","id":837221,"avatar_url":"https://avatars.githubusercontent.com/u/837221?v=3","gravatar_id":"","url":"https://api.github.com/users/mxm","html_url":"https://github.com/mxm","followers_url":"https://api.github.com/users/mxm/followers","following_url":"https://api.github.com/users/mxm/following{/other_user}","gists_url":"https://api.github.com/users/mxm/gists{/gist_id}","starred_url":"https://api.github.com/users/mxm/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mxm/subscriptions","organizations_url":"https://api.github.com/users/mxm/orgs","repos_url":"https://api.github.com/users/mxm/repos","events_url":"https://api.github.com/users/mxm/events{/privacy}","received_events_url":"https://api.github.com/users/mxm/received_events","type":"User","site_admin":false},"created_at":"2016-09-28T16:48:39Z","updated_at":"2016-09-28T16:48:39Z","body":"Merging this with a small fix. Thank you!"}}
{"actor":{"display_login":"mxm"}}