[jira] [Created] (BEAM-139) Print mode (batch/streaming) during translation

Maximilian Michels created BEAM-139: --- Summary: Print mode (batch/streaming) during translation Key: BEAM-139 URL: https://issues.apache.org/jira/browse/BEAM-139 Project: Beam Issue Type: I

[jira] [Created] (BEAM-140) Improve examples provided with the Flink runner

Maximilian Michels created BEAM-140: --- Summary: Improve examples provided with the Flink runner Key: BEAM-140 URL: https://issues.apache.org/jira/browse/BEAM-140 Project: Beam Issue Type: Im

[jira] [Commented] (BEAM-53) PubSubIO: reimplement in Java

[ https://issues.apache.org/jira/browse/BEAM-53?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15206522#comment-15206522 ] Davor Bonaci commented on BEAM-53: -- Another user question: http://stackoverflow.com/questio

[jira] [Updated] (BEAM-139) Print mode (batch/streaming) during translation

[ https://issues.apache.org/jira/browse/BEAM-139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-139: -- Assignee: Davor Bonaci (was: Frances Perry) > Print mode (batch/streaming) during translation >

[jira] [Commented] (BEAM-139) Print mode (batch/streaming) during translation

[ https://issues.apache.org/jira/browse/BEAM-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15206547#comment-15206547 ] Davor Bonaci commented on BEAM-139: --- We are hoping to be able to remove the "--streaming"

[jira] [Commented] (BEAM-140) Improve examples provided with the Flink runner

[ https://issues.apache.org/jira/browse/BEAM-140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15206563#comment-15206563 ] Davor Bonaci commented on BEAM-140: --- Perhaps we should consider unifying all the examples

[GitHub] incubator-beam pull request: [BEAM-22] Schedule roots less aggress...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/64 [BEAM-22] Schedule roots less aggressively The excess scheduling of known-empty bundles can consume excessive resources, especially with the default CachedThreadPool executor service.

[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=15206602#comment-15206602 ] ASF GitHub Bot commented on BEAM-22: GitHub user tgroh opened a pull request: https:

[jira] [Created] (BEAM-141) Remove StateSampler from Java SDK

Scott Wegner created BEAM-141: - Summary: Remove StateSampler from Java SDK Key: BEAM-141 URL: https://issues.apache.org/jira/browse/BEAM-141 Project: Beam Issue Type: Bug Components: sd

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

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

[1/2] incubator-beam git commit: Add DisplayData builder API to SDK

Repository: incubator-beam Updated Branches: refs/heads/master c984f3ae2 -> c953e7907 Add DisplayData builder API to SDK This allows generating the display data which will be attached to PTransforms. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-u

[jira] [Commented] (BEAM-118) Add DisplayData to SDK

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

[GitHub] incubator-beam pull request: [BEAM-118] Add DipslayData primitives...

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

[GitHub] incubator-beam pull request: [BEAM-119] Integrate DisplayData into...

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/65 [BEAM-119] Integrate DisplayData into DataflowPipelineRunner Translate registered display data into the job steps used by DataflowPipelineRunner. You can merge this pull request into a Git r

[jira] [Commented] (BEAM-119) Integrate DisplayData into DataflowPipelineRunner

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

[GitHub] incubator-beam pull request: Update my branch

GitHub user sammcveety opened a pull request: https://github.com/apache/incubator-beam/pull/66 Update my branch You can merge this pull request into a Git repository by running: $ git pull https://github.com/sammcveety/incubator-beam master Alternatively you can review and ap

[GitHub] incubator-beam pull request: Update my branch

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

[jira] [Updated] (BEAM-141) Remove StateSampler from Java SDK

[ https://issues.apache.org/jira/browse/BEAM-141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-141: -- Assignee: Scott Wegner (was: Davor Bonaci) > Remove StateSampler from Java SDK >

[GitHub] incubator-beam pull request: Update AutoComplete.java

GitHub user sammcveety opened a pull request: https://github.com/apache/incubator-beam/pull/67 Update AutoComplete.java Allow for the Datastore dependency of this test to be in a different project than the main project for the job. R: @dhalperi You can merge this pull requ

[jira] [Created] (BEAM-142) BigQueryIO: don't unnecessarily initialize an ExecutorService to validate parameters

Davor Bonaci created BEAM-142: - Summary: BigQueryIO: don't unnecessarily initialize an ExecutorService to validate parameters Key: BEAM-142 URL: https://issues.apache.org/jira/browse/BEAM-142 Project: Bea

[jira] [Commented] (BEAM-142) BigQueryIO: don't unnecessarily initialize an ExecutorService to validate parameters

[ https://issues.apache.org/jira/browse/BEAM-142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207317#comment-15207317 ] Luke Cwik commented on BEAM-142: If you use the executor service from PipelineOptions, it ha

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

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

[GitHub] incubator-beam pull request: [BEAM-22] Implement InProcessPipeline...

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

Repository: incubator-beam Updated Branches: refs/heads/master c953e7907 -> 90af33243 Implement InProcessPipelineRunner#run Appropriately construct an evaluation context and executor, and start the pipeline when run is called. Implement InProcessPipelineResult. Apply PTransform overrides.

[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=15207860#comment-15207860 ] ASF GitHub Bot commented on BEAM-22: Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request: make BigtableIO#Read#withRowFilter pu...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/68 make BigtableIO#Read#withRowFilter public This is https://github.com/GoogleCloudPlatform/DataflowJavaSDK/pull/150 targeted against correct repo. R: me since @nevillelyh is author.