[jira] [Updated] (BEAM-137) Add implicit conf/pipeline-default.conf options file

[ https://issues.apache.org/jira/browse/BEAM-137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-137: -- Assignee: (was: Davor Bonaci) > Add implicit conf/pipeline-default.conf options file > ---

[jira] [Commented] (BEAM-80) Support combiner lifting for (Keyed)CombineWithContext

[ https://issues.apache.org/jira/browse/BEAM-80?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205307#comment-15205307 ] Pei He commented on BEAM-80: Closed as fixed > Support combiner lifting for (Keyed)CombineWithCo

[jira] [Commented] (BEAM-96) Support composing combine functions

[ https://issues.apache.org/jira/browse/BEAM-96?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205305#comment-15205305 ] Pei He commented on BEAM-96: Closed as fixed > Support composing combine functions > ---

[jira] [Closed] (BEAM-80) Support combiner lifting for (Keyed)CombineWithContext

[ https://issues.apache.org/jira/browse/BEAM-80?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He closed BEAM-80. -- Resolution: Fixed > Support combiner lifting for (Keyed)CombineWithContext > --

[jira] [Closed] (BEAM-96) Support composing combine functions

[ https://issues.apache.org/jira/browse/BEAM-96?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He closed BEAM-96. -- Resolution: Fixed > Support composing combine functions > --- > > Key: BEAM

[jira] [Commented] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205022#comment-15205022 ] Daniel Halperin commented on BEAM-131: -- +1. Re your #2: I hope not. Specifically, I am

[jira] [Comment Edited] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205025#comment-15205025 ] Daniel Halperin edited comment on BEAM-131 at 3/21/16 8:19 PM: ---

[jira] [Commented] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205025#comment-15205025 ] Daniel Halperin commented on BEAM-131: -- [and of course if the JDBC connector is only si

[1/2] incubator-beam-site git commit: Remove trailing slash in blog "read more" links

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site d5dfeb6d2 -> 31494 Remove trailing slash in blog "read more" links Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/c1c2

[2/2] incubator-beam-site git commit: Remove trailing slash in blog "read more" links

Remove trailing slash in blog "read more" links Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/3149 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/3149 Diff: http://

[jira] [Commented] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204927#comment-15204927 ] Maximilian Michels commented on BEAM-131: - Not a silly question :) IMHO, this is wha

[1/2] incubator-beam-site git commit: Blog page "read more" links + README.md for the site.

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 2f7336f0e -> d5dfeb6d2 Blog page "read more" links + README.md for the site. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commi

[2/2] incubator-beam-site git commit: Blog page "read more" links + README.md for the site.

Blog page "read more" links + README.md for the site. This closes #4 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/d5dfeb6d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/

[jira] [Commented] (BEAM-137) Add implicit conf/pipeline-default.conf options file

[ https://issues.apache.org/jira/browse/BEAM-137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204664#comment-15204664 ] Jean-Baptiste Onofré commented on BEAM-137: --- Providing .fromFile(String path) in a

[jira] [Commented] (BEAM-137) Add implicit conf/pipeline-default.conf options file

[ https://issues.apache.org/jira/browse/BEAM-137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204657#comment-15204657 ] Luke Cwik commented on BEAM-137: The original design of PipelineOptions took into account th

[jira] [Commented] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204659#comment-15204659 ] Jean-Baptiste Onofré commented on BEAM-131: --- Fully agree, it's what I expressed in

[jira] [Commented] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204636#comment-15204636 ] Daniel Halperin commented on BEAM-131: -- This may be a silly question, but why is this i

[jira] [Commented] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

[ https://issues.apache.org/jira/browse/BEAM-138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204614#comment-15204614 ] Jean-Baptiste Onofré commented on BEAM-138: --- Oh ok, it wasn't obvious to me that B

[jira] [Resolved] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

[ https://issues.apache.org/jira/browse/BEAM-138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-138. --- Resolution: Duplicate > Extend TextIO to new protocols (and maybe rename to FileIO) > --

[jira] [Commented] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

[ https://issues.apache.org/jira/browse/BEAM-138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204593#comment-15204593 ] Frances Perry commented on BEAM-138: TextIO is really about a specific file format -- it

[jira] [Commented] (BEAM-137) Add implicit conf/pipeline-default.conf options file

[ https://issues.apache.org/jira/browse/BEAM-137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204607#comment-15204607 ] Frances Perry commented on BEAM-137: [~lcwik] Do you have plans for generalizing Pipelin

[jira] [Commented] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

[ https://issues.apache.org/jira/browse/BEAM-138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204605#comment-15204605 ] Daniel Halperin commented on BEAM-138: -- JB, want to mark this as a dupe of BEAM-59? >

[jira] [Commented] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

[ https://issues.apache.org/jira/browse/BEAM-138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204600#comment-15204600 ] Daniel Halperin commented on BEAM-138: -- https://issues.apache.org/jira/browse/BEAM-59 c

[jira] [Commented] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

[ https://issues.apache.org/jira/browse/BEAM-138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204599#comment-15204599 ] Jean-Baptiste Onofré commented on BEAM-138: --- Yes exactly. Actually, I should have

[jira] [Resolved] (BEAM-136) PipelineOptionsFactory should detect all runners

[ https://issues.apache.org/jira/browse/BEAM-136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-136. - Resolution: Fixed Resolving this since the associated pull request has been merged: https:/

[GitHub] incubator-beam pull request: Flink registrar

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

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

[2/3] incubator-beam git commit: [flink] Add FlinkRunnerRegistrar

[flink] Add FlinkRunnerRegistrar Expose Flink runner and options via AuteService. AuteService will at compile time populate META-INF/services so that Dataflow sdk can seamlessly pick up FlinkRunner. This closes #40. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: htt

[1/3] incubator-beam git commit: [flink] add test case for Runner registration

Repository: incubator-beam Updated Branches: refs/heads/master fcc6f3cfd -> c984f3ae2 [flink] add test case for Runner registration Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ba7b7a04 Tree: http://gi

[jira] [Commented] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203962#comment-15203962 ] Jean-Baptiste Onofré commented on BEAM-131: --- I think (and it's planned) it makes s

[jira] [Commented] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203960#comment-15203960 ] Maximilian Michels commented on BEAM-131: - Could we specify what exactly we want to

[jira] [Updated] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-131: Assignee: Kostas Kloudas (was: Maximilian Michels) > Write to jdbc/database > --

[jira] [Updated] (BEAM-130) Checkpointing of custom sources and sinks

[ https://issues.apache.org/jira/browse/BEAM-130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-130: Assignee: Kostas Kloudas (was: Maximilian Michels) > Checkpointing of custom sources and sink

[jira] [Created] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

Jean-Baptiste Onofré created BEAM-138: - Summary: Extend TextIO to new protocols (and maybe rename to FileIO) Key: BEAM-138 URL: https://issues.apache.org/jira/browse/BEAM-138 Project: Beam

[jira] [Created] (BEAM-137) Add implicit conf/pipeline-default.conf options file

Jean-Baptiste Onofré created BEAM-137: - Summary: Add implicit conf/pipeline-default.conf options file Key: BEAM-137 URL: https://issues.apache.org/jira/browse/BEAM-137 Project: Beam Issue