[jira] [Commented] (BEAM-1223) Add static factory methods for Sum.[*]Fn classes

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

[jira] [Updated] (BEAM-1242) convert older IO/Sources to use standard ReadTransform style

[ https://issues.apache.org/jira/browse/BEAM-1242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1242: -- Issue Type: Improvement (was: Bug) > convert older IO/Sources to use standard ReadTransform

[6/6] beam git commit: [BEAM-1231] Use well known coder types in Java

[BEAM-1231] Use well known coder types in Java This closes #1717 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5c612272 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5c612272 Diff:

[5/6] beam git commit: Use kind:* for certain well known coder types.

Use kind:* for certain well known coder types. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6947d21b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6947d21b Diff:

[jira] [Commented] (BEAM-1231) Use well known coder types in Java for WindowedValue, GlobalWindow, and LengthPrefix

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

[3/6] beam git commit: [BEAM-1231] Use well known coder types in Java

[BEAM-1231] Use well known coder types in Java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3de4108e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3de4108e Diff:

[4/6] beam git commit: Swap to use initializeCloudObject as customization point for CloudObjects. Hide StandardCoder#getComponents() and have coders only rely on Coder#getCoderArguments()

Swap to use initializeCloudObject as customization point for CloudObjects. Hide StandardCoder#getComponents() and have coders only rely on Coder#getCoderArguments() Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1b76d3dc

[GitHub] beam pull request #1717: [BEAM-1231] Use well known coder types in Java

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

[2/6] beam git commit: Fix coders to have type information and test coders with components to ensure that they serialize and deserialize correctly with well known coder types.

Fix coders to have type information and test coders with components to ensure that they serialize and deserialize correctly with well known coder types. Jackson requires type information to invoke the coder Jackson module to be able to resolve @type information. The coder Jackson module is

[jira] [Commented] (BEAM-1223) Add static factory methods for Sum.[*]Fn classes

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

[6/7] beam git commit: [BEAM-1223] Added the missing javadocs.

[BEAM-1223] Added the missing javadocs. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3e16e325 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3e16e325 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3e16e325

[2/7] beam git commit: [BEAM-1223] Reduced [Sum|Min|Max|Mean]*Fn viability so as to make them an internal implementation detail and prevent external code from employing them for tasks such as pipeline

[BEAM-1223] Reduced [Sum|Min|Max|Mean]*Fn viability so as to make them an internal implementation detail and prevent external code from employing them for tasks such as pipeline translation. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[7/7] beam git commit: [BEAM-1223] Introduced Sum, Min, Max#ofLongs()/ofDoubles()/ofIntegers()

[BEAM-1223] Introduced Sum,Min,Max#ofLongs()/ofDoubles()/ofIntegers() This closes #1723 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d86db15b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d86db15b Diff:

[jira] [Resolved] (BEAM-370) Remove the .named() methods from PTransforms and sub-classes

[ https://issues.apache.org/jira/browse/BEAM-370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Chambers resolved BEAM-370. --- Resolution: Fixed Fix Version/s: 0.5.0 > Remove the .named() methods from PTransforms and

[1/2] beam git commit: Closes #1730

Repository: beam Updated Branches: refs/heads/master 1b15d6de0 -> e794f1486 Closes #1730 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e794f148 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e794f148 Diff:

[jira] [Commented] (BEAM-1140) Apex ParDoBoundTranslatorTest.testMultiOutputParDoWithSideInputs is flaky

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

[GitHub] beam pull request #1727: [BEAM-1140] delay stream termination after final ma...

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

[2/2] beam git commit: This closes #1727

This closes #1727 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1b15d6de Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1b15d6de Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1b15d6de Branch:

[jira] [Created] (BEAM-1242) convert older IO/Sources to use standard ReadTransform style

Stephen Sisk created BEAM-1242: -- Summary: convert older IO/Sources to use standard ReadTransform style Key: BEAM-1242 URL: https://issues.apache.org/jira/browse/BEAM-1242 Project: Beam Issue

[GitHub] beam pull request #1730: [BEAM-370] Remove last mention of PTransform#named

GitHub user bjchambers opened a pull request: https://github.com/apache/beam/pull/1730 [BEAM-370] Remove last mention of PTransform#named Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [*] Make sure the PR title is

[jira] [Commented] (BEAM-370) Remove the .named() methods from PTransforms and sub-classes

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

[1/4] beam git commit: Move name utilities from StringUtils to NameUtils

Repository: beam Updated Branches: refs/heads/master 0616245e6 -> 6c1e46976 Move name utilities from StringUtils to NameUtils Add more exhaustive tests for NameUtils Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/38d902be

[3/4] beam git commit: Remove .named from Combine

Remove .named from Combine Introduces a NameOverride interface that allows some classes to define custom behavior for getting the name. This is necessary for parameterized CombineFns to expose details about their parameter values. Project: http://git-wip-us.apache.org/repos/asf/beam/repo

[2/3] beam git commit: Deliver timers in the direct runner

Deliver timers in the direct runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d4cc0c33 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d4cc0c33 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d4cc0c33

[GitHub] beam pull request #1728: [BEAM-1239] Updates Python SDK examples to use Beam...

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

[jira] [Commented] (BEAM-1232) Fix py-sdk comments to be up-to-date and valid

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

[GitHub] beam pull request #1722: [BEAM-1232] fixed comments to refer ptransform.expa...

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

[1/2] beam git commit: Updated ptransform.apply() to ptransform.expand() in the comments.

Repository: beam Updated Branches: refs/heads/python-sdk a779ac15d -> 020daa96c Updated ptransform.apply() to ptransform.expand() in the comments. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c534cf1a Tree:

[1/2] beam git commit: Updates Python SDK examples to use Beam text source/sink.

Repository: beam Updated Branches: refs/heads/python-sdk f22fb9ce5 -> a779ac15d Updates Python SDK examples to use Beam text source/sink. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/87bed83b Tree:

[2/2] beam git commit: Closes #1728

Closes #1728 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a779ac15 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a779ac15 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a779ac15 Branch:

[2/2] beam git commit: Fixed the example usage in pipeline.py

Fixed the example usage in pipeline.py It was not conforming to python-sdk. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d84ac291 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d84ac291 Diff:

[1/2] beam git commit: Closes #1691

Repository: beam Updated Branches: refs/heads/python-sdk d1906416e -> f22fb9ce5 Closes #1691 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f22fb9ce Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f22fb9ce Diff:

[jira] [Closed] (BEAM-1221) Python E2E WordCount Test in Postcommit

[ https://issues.apache.org/jira/browse/BEAM-1221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu closed BEAM-1221. -- > Python E2E WordCount Test in Postcommit > --- > > Key:

[jira] [Resolved] (BEAM-1221) Python E2E WordCount Test in Postcommit

[ https://issues.apache.org/jira/browse/BEAM-1221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu resolved BEAM-1221. Resolution: Done Fix Version/s: Not applicable > Python E2E WordCount Test in Postcommit >

[jira] [Closed] (BEAM-495) Generalize FileChecksumMatcher used for all E2E test

[ https://issues.apache.org/jira/browse/BEAM-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu closed BEAM-495. - > Generalize FileChecksumMatcher used for all E2E test > > >

[2/2] beam git commit: This closes #1720

This closes #1720 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/467e3859 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/467e3859 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/467e3859 Branch:

[1/2] beam git commit: WriteTest: use ToString#element()

Repository: beam Updated Branches: refs/heads/master 70ff6bfd9 -> 467e38596 WriteTest: use ToString#element() Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0d0e6d19 Tree:

[GitHub] beam pull request #1729: [BEAM-1240] Create RabbitMqIO

GitHub user jbonofre opened a pull request: https://github.com/apache/beam/pull/1729 [BEAM-1240] Create RabbitMqIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X] Make sure the PR title is formatted like:

[jira] [Created] (BEAM-1240) Create RabbitMqIO

Jean-Baptiste Onofré created BEAM-1240: -- Summary: Create RabbitMqIO Key: BEAM-1240 URL: https://issues.apache.org/jira/browse/BEAM-1240 Project: Beam Issue Type: New Feature

[jira] [Resolved] (BEAM-1217) Some examples fail to run due to private / public options mismatch.

[ https://issues.apache.org/jira/browse/BEAM-1217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Kuster resolved BEAM-1217. Resolution: Fixed Fix Version/s: 0.5.0 > Some examples fail to run due to private / public