[jira] [Commented] (BEAM-578) Update FileBasedSource so that implementations can control whether the source gets split into ranges

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

[GitHub] incubator-beam pull request #866: [BEAM-578] Updates FileBasedSource so that...

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

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

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 77ce9b74a -> 0af015017 Closes #866 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0af01501 Tree:

[2/2] incubator-beam git commit: Updates FileBasedSource so that sub-class can prevent splitting to data ranges.

Updates FileBasedSource so that sub-class can prevent splitting to data ranges. File patterns will be split into sources of individual files, but any further splitting into data ranges will be prevented. This prevents both initial and dynamic splitting. Introduces UnsplittableRangeTracker,

[GitHub] incubator-beam pull request #873: JUnit tests: add @RunWith annotation

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

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

Repository: incubator-beam Updated Branches: refs/heads/master 835f601a9 -> f17e7303a Closes #873 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f17e7303 Tree:

[2/2] incubator-beam git commit: JUnit tests: add @RunWith annotation

JUnit tests: add @RunWith annotation Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3b221732 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3b221732 Diff:

[GitHub] incubator-beam pull request #873: JUnit tests: add @RunWith annotation

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/873 JUnit tests: add @RunWith annotation Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[GitHub] incubator-beam pull request #872: checkstyle: prohibit API client repackaged...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/872 checkstyle: prohibit API client repackaged Guava Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[jira] [Commented] (BEAM-574) KafkaIO prints superfluous information

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

[GitHub] incubator-beam pull request #870: Write: Remove invalid import

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

[2/2] incubator-beam git commit: Write: Remove invalid import

Write: Remove invalid import Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c64e9dca Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c64e9dca Diff:

[GitHub] incubator-beam pull request #859: [BEAM-574] Remove log when new records hav...

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

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

Repository: incubator-beam Updated Branches: refs/heads/master b380a677b -> 835f601a9 Closes #870 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/835f601a Tree:

[jira] [Commented] (BEAM-261) Apache Apex Runner

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

[jira] [Commented] (BEAM-261) Apache Apex Runner

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

[jira] [Commented] (BEAM-580) Add a Datastore delete example

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

[jira] [Created] (BEAM-580) Add a Datastore delete example

Vikas Kedigehalli created BEAM-580: -- Summary: Add a Datastore delete example Key: BEAM-580 URL: https://issues.apache.org/jira/browse/BEAM-580 Project: Beam Issue Type: Improvement

[jira] [Resolved] (BEAM-571) Migrate DatastoreIO from v1beta3 to v1 version

[ https://issues.apache.org/jira/browse/BEAM-571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Kedigehalli resolved BEAM-571. Resolution: Fixed Fix Version/s: 0.3.0-incubating > Migrate DatastoreIO from v1beta3

[GitHub] incubator-beam pull request #870: Write: Remove invalid import

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/870 Write: Remove invalid import You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/incubator-beam patch-1 Alternatively you can

[GitHub] incubator-beam pull request #869: Remove legacy import order

GitHub user bjchambers opened a pull request: https://github.com/apache/incubator-beam/pull/869 Remove legacy import order Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [*] Make sure the PR title is formatted like:

[jira] [Commented] (BEAM-473) DatastoreIO querying latest timestamp statistics doesn't work with namespace

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

[GitHub] incubator-beam pull request #868: [BEAM-473]: DatastoreIO statistics query f...

GitHub user vikkyrk opened a pull request: https://github.com/apache/incubator-beam/pull/868 [BEAM-473]: DatastoreIO statistics query fixes Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[GitHub] incubator-beam pull request #860: Allow Google Cloud Dataflow workflows to u...

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

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

Closes #859 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b380a677 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b380a677 Diff:

[jira] [Commented] (BEAM-206) FileBasedSink does serial renames

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

[jira] [Closed] (BEAM-206) FileBasedSink does serial renames

[ https://issues.apache.org/jira/browse/BEAM-206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-206. Resolution: Fixed Fix Version/s: 0.3.0-incubating > FileBasedSink does serial renames >

[GitHub] incubator-beam pull request #826: [BEAM-206] FileBasedSink: improve parallel...

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

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

Repository: incubator-beam Updated Branches: refs/heads/master 064796dcc -> a8b2d6cc9 Closes #826 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a8b2d6cc Tree:

[2/2] incubator-beam git commit: FileBasedSink: improve parallelism in GCS copy/remove

FileBasedSink: improve parallelism in GCS copy/remove Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f08f21cd Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f08f21cd Diff:

[jira] [Updated] (BEAM-579) Integrate NamedAggregators into Spark's sink system

[ https://issues.apache.org/jira/browse/BEAM-579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-579: Priority: Major (was: Critical) > Integrate NamedAggregators into Spark's sink system >

[jira] [Commented] (BEAM-579) Integrate NamedAggregators into Spark's sink system

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

[GitHub] incubator-beam pull request #867: BEAM-579 Added Graphite and Csv Spark sink...

GitHub user staslev opened a pull request: https://github.com/apache/incubator-beam/pull/867 BEAM-579 Added Graphite and Csv Spark sinks 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-579) Integrate NamedAggregators into Spark's sink system

[ https://issues.apache.org/jira/browse/BEAM-579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15432450#comment-15432450 ] Stas Levin commented on BEAM-579: - I've started working on it and should have a patch pretty soon. >