[GitHub] incubator-beam pull request #1675: [Beam-1186] Migrating the remaining tests...

2016-12-21 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/1675

[Beam-1186] Migrating the remaining tests to use TestPipeline as a JUnit 
rule.

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam 
BEAM-1186-migrating-remaining-tests-to-TestPipeline-rule

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/1675.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1675


commit e6fd0b308583222b37e055476f34d020563893f5
Author: Stas Levin 
Date:   2016-12-21T15:58:35Z

[BEAM-1186] Broke AvroIOGeneratedClassTest into 2 parametrised test classes 
that support TestPipeline as a JUnit rule.

commit 52ca16451f807c026276dba9448d4c5db12c866e
Author: Stas Levin 
Date:   2016-12-21T21:00:39Z

[BEAM-1186] Broke ApproximateUniqueTest into 3 test classes that support 
TestPipeline as a JUnit rule.

commit d46f66d8c5f0f63f783561ba684dc003b3327b3a
Author: Stas Levin 
Date:   2016-12-21T21:21:11Z

[BEAM-1186] Broke SampleTest into 2 test classes that support TestPipeline 
as a JUnit rule.

commit 96da02a1c9014d186ce264c745e4fd48883dd4c3
Author: Stas Levin 
Date:   2016-12-21T21:32:27Z

[BEAM-1186] Migrated BigtableIOTest to use TestPipeline as a JUnit rule by 
stabilizing runReadTest's (read) transform name.




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #1664: [BEAM-1176] Migrating test to use TestPip...

2016-12-20 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/1664

[BEAM-1176] Migrating test to use TestPipeline as a JUnit rule

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam 
BEAM-1176-migrating-to-TestPipeline-rule

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/1664.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1664


commit 83068990d803edabee7aefa32de9542f84d087ac
Author: Stas Levin 
Date:   2016-12-18T16:25:33Z

Migrated the beam-examples-java module to TestPipeline as a JUnit rule.

commit ef9cabfc8dbc95d6f7748404740751fec5c9a17c
Author: Stas Levin 
Date:   2016-12-18T16:38:11Z

Migrated the beam-examples-java8 module to TestPipeline as a JUnit rule.

commit 6b68d7989d0a4fd591a10b49d40f9d77d29d3ac2
Author: Stas Levin 
Date:   2016-12-18T16:51:31Z

Migrated the beam-runners-core module to TestPipeline as a JUnit rule.

commit d95030560baa00e765f481fed256b9ad7ab00e53
Author: Stas Levin 
Date:   2016-12-19T08:20:16Z

Migrated the beam-runners-direct-java module to TestPipeline as a JUnit 
rule.

commit 2ea56f452f3fc19920e2b53f7effdb77e5774e76
Author: Stas Levin 
Date:   2016-12-19T21:54:47Z

Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule.
Plus, fixed some checkstyle errors from previous modules' migration.

commit 5e23bee64d0f186071cb90f95293abcfcbfb5250
Author: Stas Levin 
Date:   2016-12-19T22:01:31Z

Migrated the beam-sdks-java-extensions-join-library module to TestPipeline 
as a JUnit rule.

commit 9ae205550f222501fdc7de8d89666b98ab0f5620
Author: Stas Levin 
Date:   2016-12-20T07:54:57Z

Migrated the beam-sdks-java-extensions-sorter module to TestPipeline as a 
JUnit rule.

commit 0bf119d677112d5ed7f15623f86e5478ce949b13
Author: Stas Levin 
Date:   2016-12-20T11:26:07Z

Migrated the beam-sdks-java-io-google-cloud-platform module to TestPipeline 
as a JUnit rule.

commit d6207df93712fc53e3921f2da1ae42a86dbd9696
Author: Stas Levin 
Date:   2016-12-20T15:26:51Z

Migrated the beam-sdks-java-io-jdbc module to TestPipeline as a JUnit rule.

commit e3c5841a017fd71ac04c8550964753eb1a5fa802
Author: Stas Levin 
Date:   2016-12-20T15:31:23Z

Migrated the beam-sdks-java-io-jms module to TestPipeline as a JUnit rule.

commit 75020fbc235e4e1c57a4efd12c6a70ffcc763205
Author: Stas Levin 
Date:   2016-12-20T15:38:38Z

Migrated the beam-sdks-java-io-kafka module to TestPipeline as a JUnit rule.

commit 316ddcac2e8eadd778a20426e7e3cc746adbc767
Author: Stas Levin 
Date:   2016-12-20T15:44:15Z

Migrated the beam-sdks-java-io-kinesis module to TestPipeline as a JUnit 
rule.

commit 1e6390c917bc0365c440d505dc87e1ea6b13fe32
Author: Stas Levin 
Date:   2016-12-20T16:09:30Z

Migrated the beam-sdks-java-io-mongodb module to TestPipeline as a JUnit 
rule.

commit 51d38973076d9ed03bba2c38fe2f70b0ce17f6d4
Author: Stas Levin 
Date:   2016-12-20T16:57:57Z

Migrated the beam-sdks-java-io-java8tests module to TestPipeline as a JUnit 
rule + fixed WithTimestampsJava8Test.withTimestampsLambdaShouldApplyTimestamps.

commit 07a46f1a998f49b275d9639c92a0461d68803b77
Author: Stas Levin 
Date:   2016-12-20T17:15:44Z

Fixed checkstyle issues.




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #1595: [BEAM-85,BEAM-298] Introducing TestPipeli...

2016-12-13 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/1595

[BEAM-85,BEAM-298] Introducing TestPipelineRule.

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---

R: @tgroh, @kennknowles.

Let me know what you think.
Once this looks good we may consider changing existing `TestPipeline` 
usages to `TestPipelineRule` where applicable.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam 
BEAM-85-and-298-making-TestPipeline-a-TestRule

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/1595.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1595


commit 9cb41ae501fab8355241a79986a35684f7a886a1
Author: Stas Levin 
Date:   2016-12-13T17:27:41Z

Addressing BEAM-85 and BEAM-298, introducing TestPipelineRule.




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #1438: [BEAM-1050] Fixing pipeline's result stat...

2016-11-30 Thread staslev
Github user staslev closed the pull request at:

https://github.com/apache/incubator-beam/pull/1438


---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #1466: Aligned the Spark batch and streaming pip...

2016-11-30 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/1466

Aligned the Spark batch and streaming pipelines to adhere to 
waitUntilFinish and cancel

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---

Introduced SparkPipelineResult that should be able to better support 
PipelineResult semantics, such as waitUntilFinish and cancel. 

Also relates to BEAM-1000,  BEAM-595 and BEAM-1050 as well as to #1438.

R: @amitsela 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam spark-pipeline-result

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/1466.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1466


commit 63ba243c54dc50567fe73f88f2e8d17466121987
Author: Stas Levin 
Date:   2016-11-28T09:11:10Z

Added a SparkPipelineResult class to address 
PipelineResult#waitUntilFinish() and SparkRunner#run() semantics, also relates 
to BEAM-1000,  BEAM-595 and BEAM-1050.




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #1438: [BEAM-1050] Fixing pipeline's result stat...

2016-11-28 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/1438

[BEAM-1050] Fixing pipeline's result state in streaming mode

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---

R: @amitsela 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam fixing-BEAM-1050

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/1438.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1438


commit 412cab38c6ff4ced7a313b9c51e9e383a7df8392
Author: Stas Levin 
Date:   2016-11-28T09:11:10Z

Handled some exception flows in waitUntilFinish() so that the pipeline's 
state is correctly maintained, there's more work to be done in that department.
Also, added waitUntilFinish() to a bunch of pipeline.run() instances which 
in now needed as part of the move to a more strict waitUntilFinish() semantics.




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #1332: Trying to fix BEAM-891, which makes the b...

2016-11-10 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/1332

Trying to fix BEAM-891, which makes the build occasionally fail on In…

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam BEAM-891-flaky-build

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/1332.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1332


commit 74a78b7faa4eeb9434935a9d21053ac4cf0fb652
Author: Stas Levin 
Date:   2016-11-10T11:32:51Z

Trying to fix BEAM-891, which makes the build occasionally fail on 
IndexOutOfBoundsException.




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #1185: Fixed BEAM-816, aggregators are now repor...

2016-10-25 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/1185

Fixed BEAM-816, aggregators are now reported with full (prefixed) names

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---

R: @amitsela 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam 
BEAM-816-Aggregators-are-not-properly-named-when-reported-to-Graphite

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/1185.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1185


commit b1a5f8614ce3d3f41ee3f339cec90e7475e3bd53
Author: Stas Levin 
Date:   2016-10-25T15:23:23Z

Fixed BEAM-816, aggregators are now reported with full (prefixed) names




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #982: [BEAM-613] Revised SimpleStreamingWordCoun...

2016-09-21 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/982

[BEAM-613] Revised SimpleStreamingWordCountTest to test multiple batches

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---

R: @amitsela 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam 
BEAM-613-Improve-SimpleStreamingWordCountTest

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/982.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #982


commit b2d84ae0b97220bd2d187d17db03a47c41128365
Author: Stas Levin 
Date:   2016-09-05T15:22:59Z

Revised the test to test multiple batches




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #945: Fixed the Graphite metrics sink configurat...

2016-09-12 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/945

Fixed the Graphite metrics sink configuration for spark-submit on yarn.

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam 
BEAM-628-ClassNotFoundException-GraphiteSink

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/945.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #945


commit 6a5e99de4a995f277d0e4f76ddc45d5f2e64a707
Author: Stas Levin 
Date:   2016-09-12T08:27:22Z

Fixed the Graphite metrics sink configuration so it actually works when 
submitting using spark-submit on yarn.




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #901: [BEAM-15] Fixed StorageLevel inconsistency...

2016-09-07 Thread staslev
Github user staslev closed the pull request at:

https://github.com/apache/incubator-beam/pull/901


---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #918: [BEAM-544] Add header/footer support to Te...

2016-09-05 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/918

[BEAM-544] Add header/footer support to TextIO.Write

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---

R: @lukecwik 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam BEAM-544

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/918.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #918


commit df64df61963831f16050eb3078ddcf9ffe65c76e
Author: Stas Levin 
Date:   2016-09-05T17:26:12Z

Add header/footer support to TextIO.Write




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #901: [BEAM-15] Fixed StorageLevel inconsistency...

2016-08-28 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/901

[BEAM-15] Fixed StorageLevel inconsistency between DStream and RDD

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---

R: @amitsela 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam 
BEAM-15-fix-incompatible-StorageLevel

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/901.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #901


commit ddbba4348f21dd6868a53014b882d5b85781790e
Author: Stas Levin 
Date:   2016-08-28T13:09:42Z

Fixed StorageLevel inconsistency between DStream and RDD persist methods.




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


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

2016-08-23 Thread staslev
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 formatted like:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---

R: @amitsela 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam 
BEAM-579-NamedAggregators-And-Spark-Sink

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/867.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #867


commit cf932ff3338d5cd2573b76a30a018a1a4dd801c6
Author: staslev 
Date:   2016-08-23T12:50:59Z

Addressed BEAM-579 and added Graphite and Csv Spark sinks that support 
NamedAggregators.




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] incubator-beam pull request #809: Fixed javadoc for processBundle

2016-08-10 Thread staslev
GitHub user staslev opened a pull request:

https://github.com/apache/incubator-beam/pull/809

Fixed javadoc for processBundle

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:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---

The 2nd `li` element for `processBundle(InputT... inputElements)` was 
missing a proper closing tag.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/staslev/incubator-beam 
fix-DoFnTester-processBundle-javaDoc

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/809.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #809


commit 7b67b1ac4085351b676ad58a68c236e3fb99973e
Author: Stas Levin 
Date:   2016-08-10T12:20:50Z

Fixed javadoc for processBundle

The 2nd `li` element for `processBundle(InputT... inputElements)` was 
missing a proper closing tag.




---
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 but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---