[3/3] incubator-beam git commit: This closes #326

This closes #326 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6ec9e968 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6ec9e968 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[2/3] incubator-beam git commit: Cache read SideInput Contents in the InProcessSideInputContainer

Cache read SideInput Contents in the InProcessSideInputContainer This ensures that while processing a bundle all elements see the same contents for any SideInput Window. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-b

[1/3] incubator-beam git commit: Minor checkArgument style fix

Repository: incubator-beam Updated Branches: refs/heads/master ca01b6e60 -> 6ec9e9680 Minor checkArgument style fix Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/59a12902 Tree: http://git-wip-us.apache.

[GitHub] incubator-beam pull request: [BEAM-22] Cache SideInput contents in...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/326 --- 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

[2/3] incubator-beam git commit: Fix release profile

Fix release profile - Move assembly plugin from 'src' profile to 'release' profile. - Invoke 'release' profile, when invoking release-plugin's goals. - Fix path to the assembly configuration. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org

[1/3] incubator-beam git commit: Fix comment formatting in Flink runner's pom.xml

Repository: incubator-beam Updated Branches: refs/heads/master 7108bc025 -> ca01b6e60 Fix comment formatting in Flink runner's pom.xml The triple '---' trips release plugin, causing a build-time error. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip

[GitHub] incubator-beam pull request: Fix various things needed for a relea...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/327 --- 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

[3/3] incubator-beam git commit: This closes #327

This closes #327 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ca01b6e6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ca01b6e6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[jira] [Commented] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280929#comment-15280929 ] Jean-Baptiste Onofré commented on BEAM-242: --- Related to the Flink runner, there ar

[GitHub] incubator-beam pull request: Fix various things needed for a relea...

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam/pull/327 Fix various things needed for a release Fix comment formatting in Flink runner's pom.xml: * The triple '---' trips release plugin, causing a build-time error. Fix release pro

[GitHub] incubator-beam pull request: fix ConcurrentModificationException i...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/290 --- 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

[1/2] incubator-beam git commit: Closes #290

Repository: incubator-beam Updated Branches: refs/heads/master e6cb86a3c -> 7108bc025 Closes #290 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7108bc02 Tree: http://git-wip-us.apache.org/repos/asf/incu

[2/2] incubator-beam git commit: [BEAM-52] Fix a ConcurrentModificationException in KafkaIO

[BEAM-52] Fix a ConcurrentModificationException in KafkaIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/93931f3a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/93931f3a Diff: http://git-w

[jira] [Resolved] (BEAM-225) Create Class for Common TypeDescriptors

[ https://issues.apache.org/jira/browse/BEAM-225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-225. -- Resolution: Fixed > Create Class for Common TypeDescriptors >

[jira] [Created] (BEAM-278) Add I/O section

Devin Donnelly created BEAM-278: --- Summary: Add I/O section Key: BEAM-278 URL: https://issues.apache.org/jira/browse/BEAM-278 Project: Beam Issue Type: Sub-task Reporter: Devin Donne

[jira] [Created] (BEAM-276) Add PCollections Section

Devin Donnelly created BEAM-276: --- Summary: Add PCollections Section Key: BEAM-276 URL: https://issues.apache.org/jira/browse/BEAM-276 Project: Beam Issue Type: Sub-task Reporter: De

[jira] [Created] (BEAM-275) Add Pipelines Section

Devin Donnelly created BEAM-275: --- Summary: Add Pipelines Section Key: BEAM-275 URL: https://issues.apache.org/jira/browse/BEAM-275 Project: Beam Issue Type: Sub-task Reporter: Devin

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

[ https://issues.apache.org/jira/browse/BEAM-22?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280720#comment-15280720 ] ASF GitHub Bot commented on BEAM-22: GitHub user tgroh opened a pull request: https:

[GitHub] incubator-beam pull request: [BEAM-22] Cache SideInput contents in...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/326 [BEAM-22] Cache SideInput contents in InProcessSideInputContainer Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure t

[1/2] incubator-beam git commit: More regularly schedule additional roots

Repository: incubator-beam Updated Branches: refs/heads/master a25fd05e0 -> e6cb86a3c More regularly schedule additional roots This ensures that even when elements are pushed back into the Pipeline Runner, roots are scheduled if necessary. As elements may be rescheduled indefinitely, this is

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

[ https://issues.apache.org/jira/browse/BEAM-22?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280718#comment-15280718 ] ASF GitHub Bot commented on BEAM-22: Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request: [BEAM-22] More regularly schedule add...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/322 --- 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

[2/2] incubator-beam git commit: This closes #322

This closes #322 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e6cb86a3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e6cb86a3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[jira] [Created] (BEAM-277) Add Transforms Section

Devin Donnelly created BEAM-277: --- Summary: Add Transforms Section Key: BEAM-277 URL: https://issues.apache.org/jira/browse/BEAM-277 Project: Beam Issue Type: Sub-task Reporter: Devi

[jira] [Created] (BEAM-274) Add Programming Guide Skeleton

Devin Donnelly created BEAM-274: --- Summary: Add Programming Guide Skeleton Key: BEAM-274 URL: https://issues.apache.org/jira/browse/BEAM-274 Project: Beam Issue Type: Sub-task Report

[GitHub] incubator-beam pull request: [BEAM-22] Use an AtomicReference in I...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/318 --- 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

[1/3] incubator-beam git commit: Add TypeDescriptors utility class

Repository: incubator-beam Updated Branches: refs/heads/master 9a8688bc3 -> a25fd05e0 Add TypeDescriptors utility class This adds static utility methods for quickly creating readable TypeDescriptor instances for compound types, such as KVs, Lists, and Iterables. Project: http://git-wip-us.ap

[jira] [Commented] (BEAM-225) Create Class for Common TypeDescriptors

[ https://issues.apache.org/jira/browse/BEAM-225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280522#comment-15280522 ] ASF GitHub Bot commented on BEAM-225: - Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request: [BEAM-225] Create Class for Common Ty...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/275 --- 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

[3/3] incubator-beam git commit: This closes #275

This closes #275 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a25fd05e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a25fd05e Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[2/3] incubator-beam git commit: Add a couple more tests for TypeDescriptors

Add a couple more tests for TypeDescriptors Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/77fe0162 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/77fe0162 Diff: http://git-wip-us.apache.or

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

[ https://issues.apache.org/jira/browse/BEAM-22?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280504#comment-15280504 ] ASF GitHub Bot commented on BEAM-22: Github user asfgit closed the pull request at:

[1/2] incubator-beam git commit: Reuse DoFns in ParDoEvaluators

Repository: incubator-beam Updated Branches: refs/heads/master be9b15803 -> 9a8688bc3 Reuse DoFns in ParDoEvaluators This allows the runner to avoid cloning DoFns for every input bundle. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/

[2/2] incubator-beam git commit: This closes #320

This closes #320 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9a8688bc Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9a8688bc Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[GitHub] incubator-beam pull request: [BEAM-22] Reuse DoFns in ParDoEvaluat...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/320 --- 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

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

[ https://issues.apache.org/jira/browse/BEAM-22?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280500#comment-15280500 ] ASF GitHub Bot commented on BEAM-22: Github user asfgit closed the pull request at:

[1/2] incubator-beam git commit: Use an AtomicReference in InProcessSideInputContainer

Repository: incubator-beam Updated Branches: refs/heads/master 351fc3efa -> be9b15803 Use an AtomicReference in InProcessSideInputContainer This fixes a TOCTOU race in the contents updating logic, where the determination that the current pane should replace the contents of the side input and t

[2/2] incubator-beam git commit: This closes #318

This closes #318 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/be9b1580 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/be9b1580 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[1/2] incubator-beam git commit: Verify one element per window for DataflowPipelineRunner View.asSingleton

Repository: incubator-beam Updated Branches: refs/heads/master 9f796e22f -> 351fc3efa Verify one element per window for DataflowPipelineRunner View.asSingleton This changes the expansion of the DataflowPipelineRunner override for View.asSingleton to provide a useful error message to users if t

[GitHub] incubator-beam pull request: Verify one element per window for Dat...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/317 --- 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

[2/2] incubator-beam git commit: This closes #317

This closes #317 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/351fc3ef Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/351fc3ef Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[jira] [Commented] (BEAM-117) Implement the API for Static Display Metadata

[ https://issues.apache.org/jira/browse/BEAM-117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280395#comment-15280395 ] ASF GitHub Bot commented on BEAM-117: - GitHub user swegner opened a pull request: h

[GitHub] incubator-beam pull request: [BEAM-117] Validate display data regi...

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/325 [BEAM-117] Validate display data registration in Dataflow Runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure

[jira] [Commented] (BEAM-248) Register DisplayData from anonymous implementation PTransforms

[ https://issues.apache.org/jira/browse/BEAM-248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280381#comment-15280381 ] ASF GitHub Bot commented on BEAM-248: - Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request: [BEAM-248] Add display data to additi...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/280 --- 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

[1/9] incubator-beam git commit: Fix BigQuery sink display data

Repository: incubator-beam Updated Branches: refs/heads/master acb040684 -> 9f796e22f Fix BigQuery sink display data Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/489298fc Tree: http://git-wip-us.apache

[3/9] incubator-beam git commit: Add display data for MapElements transform

Add display data for MapElements transform Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0dab643a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0dab643a Diff: http://git-wip-us.apache.org

[2/9] incubator-beam git commit: Exclude default Window.allowedLateness display data

Exclude default Window.allowedLateness display data Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d9355c28 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d9355c28 Diff: http://git-wip-us.a

[8/9] incubator-beam git commit: Exclude OffsetBasedSource minBundleSize default

Exclude OffsetBasedSource minBundleSize default Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/007526f5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/007526f5 Diff: http://git-wip-us.apach

[6/9] incubator-beam git commit: Fix Write transform primitive display data

Fix Write transform primitive display data Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ea8019ec Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ea8019ec Diff: http://git-wip-us.apache.org

[5/9] incubator-beam git commit: Exclude JsonIgnore PipelineOptions from DisplayData

Exclude JsonIgnore PipelineOptions from DisplayData Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/43085f7e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/43085f7e Diff: http://git-wip-us.a

[7/9] incubator-beam git commit: Fix Combine transform primitive display data

Fix Combine transform primitive display data Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9f6c27c5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9f6c27c5 Diff: http://git-wip-us.apache.o

[9/9] incubator-beam git commit: This closes #280

This closes #280 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9f796e22 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9f796e22 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[4/9] incubator-beam git commit: Test utility for display data in a pipeline runner

Test utility for display data in a pipeline runner DisplayDataEvaluator is useful for validating how PTransform display data is surfaced in the context of a Pipeline and runner. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/inc

[jira] [Commented] (BEAM-272) Flink Runner depends on Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279893#comment-15279893 ] ASF GitHub Bot commented on BEAM-272: - GitHub user mxm opened a pull request: https

[GitHub] incubator-beam pull request: [BEAM-272][flink] remove dependency o...

GitHub user mxm opened a pull request: https://github.com/apache/incubator-beam/pull/324 [BEAM-272][flink] remove dependency on Dataflow Runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X] Make sure the PR title i

[jira] [Created] (BEAM-273) Update Flink Runner version

Maximilian Michels created BEAM-273: --- Summary: Update Flink Runner version Key: BEAM-273 URL: https://issues.apache.org/jira/browse/BEAM-273 Project: Beam Issue Type: Task Compone

[jira] [Updated] (BEAM-100) Update Flink Runner to 1.0.0

[ https://issues.apache.org/jira/browse/BEAM-100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-100: Issue Type: Sub-task (was: Task) Parent: BEAM-273 > Update Flink Runner to 1.0.0 > --

[jira] [Commented] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279851#comment-15279851 ] Maximilian Michels commented on BEAM-242: - Great! > Enable Checkstyle check for the

[jira] [Created] (BEAM-272) Flink Runner depends on Dataflow Runner

Maximilian Michels created BEAM-272: --- Summary: Flink Runner depends on Dataflow Runner Key: BEAM-272 URL: https://issues.apache.org/jira/browse/BEAM-272 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279839#comment-15279839 ] Jean-Baptiste Onofré commented on BEAM-242: --- Hi Max, yes, I have a PR on the way (

[jira] [Commented] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279835#comment-15279835 ] Maximilian Michels commented on BEAM-242: - Are you still working on this [~jbonofre]

[jira] [Updated] (BEAM-102) Side Inputs for Streaming

[ https://issues.apache.org/jira/browse/BEAM-102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-102: Assignee: Aljoscha Krettek (was: Maximilian Michels) > Side Inputs for Streaming > --

[jira] [Assigned] (BEAM-102) Side Inputs for Streaming

[ https://issues.apache.org/jira/browse/BEAM-102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-102: --- Assignee: Maximilian Michels > Side Inputs for Streaming > - >

[jira] [Resolved] (BEAM-127) Support for Unbounded sinks in Streaming

[ https://issues.apache.org/jira/browse/BEAM-127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-127. - Resolution: Fixed Assignee: Maximilian Michels (was: Kostas Kloudas) UnboundedFlinkSi

[jira] [Commented] (BEAM-236) Implement Windowing in batch execution

[ https://issues.apache.org/jira/browse/BEAM-236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279819#comment-15279819 ] Maximilian Michels commented on BEAM-236: - +1 Fixing BEAM-270 will actually mean imp

[jira] [Closed] (BEAM-236) Implement Windowing in batch execution

[ https://issues.apache.org/jira/browse/BEAM-236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-236. - Resolution: Duplicate Superseded by BEAM-270 > Implement Windowing in batch execution > ---

[jira] [Commented] (BEAM-270) Support Timestamps/Windows in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279741#comment-15279741 ] Aljoscha Krettek commented on BEAM-270: --- I added the window thing here as well, becaus

[jira] [Assigned] (BEAM-270) Use WindowedValue in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned BEAM-270: - Assignee: Aljoscha Krettek > Use WindowedValue in Flink Batch > ---

[jira] [Updated] (BEAM-270) Support Timestamps/Windows in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-270: -- Description: Right now, Flink Batch execution does not use {{WindowedValue}} internally, this mean

[jira] [Updated] (BEAM-270) Support Timestamps/Windows in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-270: -- Summary: Support Timestamps/Windows in Flink Batch (was: Use WindowedValue in Flink Batch) > Sup