incubator-beam git commit: Change counter name in TestDataflowRunner

2016-12-19 Thread bchambers
11:12:12 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Mon Dec 19 12:28:19 2016 -0800 -- .../dataflow/testing/TestDataflowRunner.java| 29 .../testing/TestDataflowRunnerTest.ja

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

2016-12-19 Thread bchambers
/diff/a972b233 Branch: refs/heads/master Commit: a972b23302146e686e0f0e141093f899e5e70555 Parents: 66318d8 998cabc Author: bchambers <bchamb...@google.com> Authored: Mon Dec 19 11:30:20 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Mon Dec 19 11:30:2

[1/2] incubator-beam git commit: Add RunnableOnService test for Metrics

2016-12-19 Thread bchambers
pos/asf/incubator-beam/diff/998cabc8 Branch: refs/heads/master Commit: 998cabc8bbbf8d08d7bfad71e9376707388f5c5c Parents: 66318d8 Author: bchambers <bchamb...@google.com> Authored: Thu Dec 15 17:04:59 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Mon Dec 19 11:2

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

2016-12-16 Thread bchambers
/diff/abdbee61 Branch: refs/heads/master Commit: abdbee61c7fa2383343f86f3e88f134163177439 Parents: 1ee191f 92dbab8 Author: bchambers <bchamb...@google.com> Authored: Fri Dec 16 16:26:43 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Fri Dec 16 16:26:4

[1/2] incubator-beam git commit: checkstyle: missed newline in DistributionCell

2016-12-16 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master 1ee191fb8 -> abdbee61c checkstyle: missed newline in DistributionCell Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/92dbab8e Tree:

[2/2] incubator-beam git commit: Make {Metric, Counter, Distribution}Cell public

2016-12-16 Thread bchambers
: cfd1633a441f98d100bd995bd811b6b8fa2cd62d Parents: cc28f0c Author: bchambers <bchamb...@google.com> Authored: Wed Dec 14 15:46:50 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Fri Dec 16 14:26:35 2016 -0800 -- ..

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

2016-12-16 Thread bchambers
asf/incubator-beam/tree/1ee191fb Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1ee191fb Branch: refs/heads/master Commit: 1ee191fb80ed1644b275a87fc02c11eae47904c2 Parents: cc28f0c cfd1633 Author: bchambers <bchamb...@google.com> Authored: Fri Dec 16 14:26:35 2016 -0800

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

2016-12-12 Thread bchambers
/diff/98543e96 Branch: refs/heads/master Commit: 98543e96fb1dc84d7ef566dc12407208b8d48144 Parents: bfd21d7 cfb71e7 Author: bchambers <bchamb...@google.com> Authored: Mon Dec 12 12:48:09 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Mon Dec 12 12:48:0

[1/2] incubator-beam git commit: Display data keys in Python should be snake_case

2016-12-06 Thread bchambers
hor: Pablo <pabl...@google.com> Authored: Mon Nov 28 13:05:47 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Tue Dec 6 17:17:16 2016 -0800 -- sdks/python/apache_beam/io/avroio.py| 8 +++---

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

2016-12-06 Thread bchambers
/diff/d5e8c79a Branch: refs/heads/python-sdk Commit: d5e8c79a3f9f4ffabaff06629a8763e74254688c Parents: f19f767 0dcc9bc Author: bchambers <bchamb...@google.com> Authored: Tue Dec 6 17:17:50 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Tue Dec 6 17:17:5

[2/4] incubator-beam git commit: [BEAM-1047] Add DataflowClient wrapper on top of JSON library.

2016-12-06 Thread bchambers
://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e8c9686a Branch: refs/heads/master Commit: e8c9686a2e898d38afd692328eb171c542084747 Parents: ded5883 Author: Pei He <pe...@google.com> Authored: Wed Nov 23 15:59:56 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Tue

[3/4] incubator-beam git commit: [Code Health] Remove redundant projectId from DataflowPipelineJob.

2016-12-06 Thread bchambers
: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ded58832 Branch: refs/heads/master Commit: ded58832ceaef487f4590d9396f09744288c955d Parents: afedd68 Author: Pei He <pe...@google.com> Authored: Wed Nov 23 16:14:27 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed:

[4/4] incubator-beam git commit: Closes #1434

2016-12-06 Thread bchambers
/diff/b2b570f2 Branch: refs/heads/master Commit: b2b570f27808b1671bf6cd0fc60f874da671d4ca Parents: afedd68 ce03f30 Author: bchambers <bchamb...@google.com> Authored: Tue Dec 6 17:08:13 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Tue Dec 6 17:08:1

[1/4] incubator-beam git commit: [BEAM-1047] Update dataflow runner code to use DataflowClient wrapper.

2016-12-06 Thread bchambers
ored: Mon Nov 28 11:47:42 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Tue Dec 6 17:08:12 2016 -0800 -- .../beam/runners/dataflow/DataflowClient.java | 36 +--- .../r

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

2016-11-21 Thread bchambers
pos/asf/incubator-beam/tree/b4fc20e4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b4fc20e4 Branch: refs/heads/python-sdk Commit: b4fc20e4432d2b956a0333d8e0c6b9aeb472a804 Parents: 50afc87 c127f7a Author: bchambers <bchamb...@google.com> Authored: Mon Nov 21 16:21:26 2

[2/2] incubator-beam git commit: Fixing error with PipelineOptions DisplayData of lists

2016-11-21 Thread bchambers
-us.apache.org/repos/asf/incubator-beam/diff/c127f7a9 Branch: refs/heads/python-sdk Commit: c127f7a9e6f9885bc595e1462b27b6961c0f465d Parents: 50afc87 Author: Pablo <pabl...@google.com> Authored: Mon Nov 21 11:15:37 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Mon Nov

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

2016-11-18 Thread bchambers
asf/incubator-beam/tree/bb9c3866 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/bb9c3866 Branch: refs/heads/master Commit: bb9c3866421863b257470ec9fb6bcb8328158045 Parents: 4852d2e 5fc68a5 Author: bchambers <bchamb...@google.com> Authored: Fri Nov 18 09:55:29 2016 -0800

[2/2] incubator-beam git commit: Remove dead code from MetricsContainer

2016-11-18 Thread bchambers
/repos/asf/incubator-beam/diff/5fc68a5c Branch: refs/heads/master Commit: 5fc68a5c109fdbe3ed8afb370c8fcee803e9f1d8 Parents: 4852d2e Author: bchambers <bchamb...@google.com> Authored: Thu Nov 17 14:40:52 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Fri Nov 18 09:55:2

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

2016-10-21 Thread bchambers
/diff/18e5d128 Branch: refs/heads/master Commit: 18e5d128b7918f743c57d8c735452b559bea25e8 Parents: 1533511 4869ef1 Author: bchambers <bchamb...@google.com> Authored: Fri Oct 21 13:27:37 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Fri Oct 21 13:27:3

[1/2] incubator-beam git commit: Use DisplayData delegate in Dataflow Read transform override

2016-10-21 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master 153351126 -> 18e5d128b Use DisplayData delegate in Dataflow Read transform override Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4869ef19

[2/3] incubator-beam git commit: Add Display Data 'path' metadata

2016-10-20 Thread bchambers
ct 12 14:49:41 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Oct 20 11:10:13 2016 -0700 -- .../core/UnboundedReadFromBoundedSource.java| 2 +- runners/direct-java/pom.xml

[1/5] incubator-beam git commit: Implement Metrics in the DirectRunner

2016-10-13 Thread bchambers
wip-us.apache.org/repos/asf/incubator-beam/tree/834933c5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/834933c5 Branch: refs/heads/master Commit: 834933c520997b4f83cf8b04219c2c63dac61e61 Parents: 51fee39 Author: bchambers <bchamb...@google.com> Authored: Wed Oct 12 10:55:53 2

[5/5] incubator-beam git commit: Closes #1024

2016-10-13 Thread bchambers
/diff/3c731707 Branch: refs/heads/master Commit: 3c731707b2d986e7a460907c8f64bbebf1dff714 Parents: e969f3d 834933c Author: bchambers <bchamb...@google.com> Authored: Thu Oct 13 15:29:30 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Oct 13 15:29:3

[3/5] incubator-beam git commit: Initial Metrics API for Beam Java

2016-10-13 Thread bchambers
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8524ed95/sdks/java/core/src/test/java/org/apache/beam/sdk/metrics/MetricsMapTest.java -- diff --git

[2/5] incubator-beam git commit: Add the ability to query metrics on PipelineResult

2016-10-13 Thread bchambers
://git-wip-us.apache.org/repos/asf/incubator-beam/tree/51fee39b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/51fee39b Branch: refs/heads/master Commit: 51fee39b7bc66d7f60ea2e0ce31e3cb516a89305 Parents: 8524ed9 Author: bchambers <bchamb...@google.com> Authored: Wed Oct 12 10

[4/5] incubator-beam git commit: Initial Metrics API for Beam Java

2016-10-13 Thread bchambers
/repos/asf/incubator-beam/diff/8524ed95 Branch: refs/heads/master Commit: 8524ed9545f5af4bdeb54601f333549b34eb35aa Parents: e969f3d Author: bchambers <bchamb...@google.com> Authored: Wed Oct 12 10:29:50 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Oct 13 15:29:2

[3/4] incubator-beam git commit: [BEAM-65] SplittableDoFn prototype.

2016-10-12 Thread bchambers
17:13:53 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Oct 12 17:29:20 2016 -0700 -- runners/core-java/pom.xml | 6 + .../runners/core/ElementAndRestriction.java | 42

[2/4] incubator-beam git commit: [BEAM-65] SplittableDoFn prototype.

2016-10-12 Thread bchambers
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a0a24883/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnAdapters.java -- diff --git

[1/4] incubator-beam git commit: [BEAM-65] SplittableDoFn prototype.

2016-10-12 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master a5d129361 -> 13b45895e http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a0a24883/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/reflect/DoFnInvokersTest.java

[4/4] incubator-beam git commit: Closes #896

2016-10-12 Thread bchambers
/13b45895 Branch: refs/heads/master Commit: 13b45895eb13cd48557472463404bd097d7097d7 Parents: a5d1293 a0a2488 Author: bchambers <bchamb...@google.com> Authored: Wed Oct 12 17:29:21 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Oct 12 17:29:2

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

2016-09-30 Thread bchambers
/diff/bc80ee34 Branch: refs/heads/master Commit: bc80ee342749768bbfc2a9fda80a4b15680e5898 Parents: b237e2f 3e7c396 Author: bchambers <bchamb...@google.com> Authored: Fri Sep 30 16:12:47 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Fri Sep 30 16:12:4

[1/2] incubator-beam git commit: Enable EncodabilityEnforcement by default

2016-09-30 Thread bchambers
wip-us.apache.org/repos/asf/incubator-beam/diff/cdd88a98 Branch: refs/heads/master Commit: cdd88a983fd2937110d52ea4661e256c8f4422f6 Parents: 0d229f5 Author: Thomas Groh <tg...@google.com> Authored: Tue Aug 23 09:37:07 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Fri Sep 3

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

2016-09-30 Thread bchambers
/7d46698f Branch: refs/heads/master Commit: 7d46698f2878e41369077c75f9347aafbeff0c5a Parents: 0d229f5 cdd88a9 Author: bchambers <bchamb...@google.com> Authored: Fri Sep 30 11:24:22 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Fri Sep 30 11:24:2

[1/2] incubator-beam git commit: Dedups TimerInternal implementations

2016-09-30 Thread bchambers
781 Branch: refs/heads/master Commit: 425c77818fc7bbd919fd1ed10a1c3a10b3bfb920 Parents: e7684b7 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Wed Sep 28 19:19:12 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Fri Sep 30 11:1

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

2016-09-30 Thread bchambers
/diff/0d229f5a Branch: refs/heads/master Commit: 0d229f5a69059024377202e09eab7d2a2f332a84 Parents: e7684b7 425c778 Author: bchambers <bchamb...@google.com> Authored: Fri Sep 30 11:12:39 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Fri Sep 30 11:12:3

[2/3] incubator-beam git commit: More changes to DoFn{Signatures, Invokers}

2016-09-12 Thread bchambers
..@google.com> Authored: Thu Aug 11 17:13:53 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon Sep 12 10:08:57 2016 -0700 -- .../beam/sdk/transforms/DoFnAdapters.java | 2 +- .../

[1/3] incubator-beam git commit: More changes to DoFn{Signatures, Invokers}

2016-09-12 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master 05c6c2749 -> b304d037f http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/75c8bb8d/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/reflect/DoFnSignaturesTest.java

[2/2] incubator-beam git commit: Remove EvaluationContext as a forApplication Parameter

2016-09-12 Thread bchambers
/diff/c2970aa7 Branch: refs/heads/master Commit: c2970aa7cc10e5e2d4bdc9c939a30df686c41ad2 Parents: 643cf63 Author: Thomas Groh <tg...@google.com> Authored: Thu Sep 8 13:41:52 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon Sep 12 09:53:1

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

2016-09-12 Thread bchambers
asf/incubator-beam/tree/05c6c274 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/05c6c274 Branch: refs/heads/master Commit: 05c6c2749f667c9e90569dd2933b17f4385f931c Parents: 643cf63 c2970aa Author: bchambers <bchamb...@google.com> Authored: Mon Sep 12 09:53:16 2016 -0700

[1/2] incubator-beam git commit: Add Latest CombineFn and PTransforms

2016-09-01 Thread bchambers
t;sweg...@google.com> Authored: Thu Aug 18 13:56:34 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Sep 1 13:16:02 2016 -0700 -- .../apache/beam/sdk/coders/NullableCoder.java | 7 + .../

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

2016-09-01 Thread bchambers
/268ec11c Branch: refs/heads/master Commit: 268ec11c62f0803e2eef5c5f1715b270d261c3a6 Parents: f657956 0d3f2f2 Author: bchambers <bchamb...@google.com> Authored: Thu Sep 1 13:16:47 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Sep 1 13:16:4

[1/2] incubator-beam git commit: Remove empty unused method in TestStreamEvaluatorFactory

2016-08-31 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master a5320607a -> f65795661 Remove empty unused method in TestStreamEvaluatorFactory Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ccfb78ea

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

2016-08-31 Thread bchambers
/f6579566 Branch: refs/heads/master Commit: f65795661a9d9b20c757791b953bd343b461b582 Parents: a532060 ccfb78e Author: bchambers <bchamb...@google.com> Authored: Wed Aug 31 15:54:20 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Aug 31 15:54:2

[1/2] incubator-beam git commit: Test that multiple instances of TestStream are supported

2016-08-31 Thread bchambers
Committer: bchambers <bchamb...@google.com> Committed: Wed Aug 31 15:00:39 2016 -0700 -- .../beam/runners/direct/KeyedResourcePool.java | 47 + .../runners/direct/LockedKeyedResourcePool.java | 95 ++

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

2016-08-31 Thread bchambers
/a5320607 Branch: refs/heads/master Commit: a5320607af10dd6b45440384b8afbbc8ad9889b7 Parents: 7dcb4c7 8968097 Author: bchambers <bchamb...@google.com> Authored: Wed Aug 31 15:01:53 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Aug 31 15:01:5

[1/2] incubator-beam git commit: Correct some accidental renames

2016-08-31 Thread bchambers
mit: f70aa49e2babc79a65a339309776837be2a45126 Parents: 98da6e8 Author: bchambers <bchamb...@google.com> Authored: Wed Aug 3 13:38:43 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Aug 31 10:23:29 2016 -0700 -- .../main/java/org/

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

2016-08-31 Thread bchambers
/7dcb4c72 Branch: refs/heads/master Commit: 7dcb4c72cd7e2be0ccaa30424226a3451e903f76 Parents: 98da6e8 f70aa49 Author: bchambers <bchamb...@google.com> Authored: Wed Aug 31 10:23:30 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Aug 31 10:23:3

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

2016-08-17 Thread bchambers
asf/incubator-beam/tree/d93ef2ed Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d93ef2ed Branch: refs/heads/master Commit: d93ef2edd260a2077bc2ba6abd1ca02abd147a9a Parents: 89367cf 236945d Author: bchambers <bchamb...@google.com> Authored: Wed Aug 17 16:09:01 2016 -0700

[3/4] incubator-beam git commit: Rewrites DoFnReflector to go via DoFnSignature

2016-08-17 Thread bchambers
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/fbf77f90 Branch: refs/heads/master Commit: fbf77f90e0391304a580178f99441256526c4b0e Parents: 4609773 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Tue Aug 9 17:16:00 2016 -0700 Committer: bchambers <bchamb...@g

[2/4] incubator-beam git commit: Rewrites DoFnReflector to go via DoFnSignature

2016-08-17 Thread bchambers
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/fbf77f90/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java -- diff --git

[4/4] incubator-beam git commit: Closes #812

2016-08-17 Thread bchambers
/89367cfb Branch: refs/heads/master Commit: 89367cfb19ae86d66441970277177512961d3b6a Parents: 4609773 fbf77f9 Author: bchambers <bchamb...@google.com> Authored: Wed Aug 17 15:43:47 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Aug 17 15:43:4

[1/4] incubator-beam git commit: Rewrites DoFnReflector to go via DoFnSignature

2016-08-17 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master 46097736b -> 89367cfb1 http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/fbf77f90/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/reflect/DoFnSignaturesTest.java

[3/3] incubator-beam git commit: This closes #815

2016-08-11 Thread bchambers
/diff/a0769ad2 Branch: refs/heads/master Commit: a0769ad2a348c1296086b9dc8994e32ba5a06760 Parents: 3a858ee d20a7ad Author: bchambers <bchamb...@google.com> Authored: Thu Aug 11 10:28:04 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Aug 11 11:06:5

[1/2] incubator-beam git commit: Demonstrate that the DirectRunner runs per-call

2016-08-10 Thread bchambers
2ad Author: Thomas Groh <tg...@google.com> Authored: Wed Aug 10 11:29:38 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Aug 10 15:54:09 2016 -0700 -- .../apache/beam/runners/direct/DirectRunne

[1/2] incubator-beam git commit: Add ElementByteSizeObservable default constructor

2016-08-02 Thread bchambers
mit/d73e614b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d73e614b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d73e614b Branch: refs/heads/master Commit: d73e614b7bd722773882a0da36bc87f84c499a00 Parents: f13725f aae1b01 Author: bchambers <bchamb...@goog

[2/2] incubator-beam git commit: Add ElementByteSizeObserver default constructor

2016-08-02 Thread bchambers
Branch: refs/heads/master Commit: aae1b010e9da59dbd68ce24401f15561440f2bee Parents: f13725f Author: bchambers <bchamb...@google.com> Authored: Mon Aug 1 10:37:14 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue Aug 2 09:55:3

[1/2] incubator-beam git commit: Implement Aggregators directly for direct-java

2016-07-28 Thread bchambers
7bb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/15eb67bb Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/15eb67bb Branch: refs/heads/master Commit: 15eb67bb06f7cf0f225249810df8b521649f4f23 Parents: 9c44751 Author: bchambers <bchamb...@google.com> Authored: T

[2/2] incubator-beam git commit: Implement aggregators directly in the direct runner

2016-07-28 Thread bchambers
: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1df6f5f9 Branch: refs/heads/master Commit: 1df6f5f976108aa584abbb8a9412578e1f6a621b Parents: 9c44751 15eb67b Author: bchambers <bchamb...@google.com> Authored: Thu Jul 28 17:22:03 2016 -0700 Committer: bchambers <bchamb...@g

[1/3] incubator-beam git commit: Remove many definitions of named methods

2016-06-27 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master 4f580f5f1 -> 9abd0926a Remove many definitions of named methods Specifically, remove the occurrences in: - Window - AvroIO - PubsubIO - TextIO - BigQueryIO - Read Project:

[3/3] incubator-beam git commit: This closes #529

2016-06-27 Thread bchambers
/diff/9abd0926 Branch: refs/heads/master Commit: 9abd0926ac471c178eb30eeb01c964f9ecbd9cce Parents: 4f580f5 fc52a10 Author: bchambers <bchamb...@google.com> Authored: Mon Jun 27 10:29:31 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon Jun 27 10:29:3

[2/3] incubator-beam git commit: Remove many uses of .named methods

2016-06-27 Thread bchambers
Remove many uses of .named methods Specifically, remove uses of: - Window.named - AvroIO.named - PubSubIO.named - TextIO.named - BigQueryIO.named - Read.named Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[3/3] incubator-beam git commit: This closes #522

2016-06-24 Thread bchambers
/diff/41faee4f Branch: refs/heads/master Commit: 41faee4f9cbe29ad6a80742789a0004abe59e684 Parents: 7745b92 4f050bf Author: bchambers <bchamb...@google.com> Authored: Thu Jun 23 22:55:46 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Jun 23 22:55:4

[2/3] incubator-beam git commit: Remove uses of ParDo.named

2016-06-24 Thread bchambers
-0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Jun 23 22:55:43 2016 -0700 -- .../apache/beam/examples/MinimalWordCount.java | 2 +- .../beam/examples/complete/AutoComplete.java| 4 +- .../apache/b

[1/3] incubator-beam git commit: Remove ParDo.named on all variants

2016-06-24 Thread bchambers
016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Jun 23 22:55:43 2016 -0700 -- .../org/apache/beam/sdk/transforms/ParDo.java | 70 +--- 1 file changed, 3 insertions(+

[1/2] incubator-beam git commit: [BEAM-359] Treat erased type variables as non-deterministic in AvroCoder

2016-06-22 Thread bchambers
wip-us.apache.org/repos/asf/incubator-beam/diff/9c8dc4fe Branch: refs/heads/master Commit: 9c8dc4fe920618253b425f0d998f8d63552ec358 Parents: 9bcf9b0 Author: bchambers <bchamb...@google.com> Authored: Tue Jun 21 13:42:33 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed

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

2016-06-22 Thread bchambers
/diff/8949ec31 Branch: refs/heads/master Commit: 8949ec3159d552be108819d7951b649c00271dd7 Parents: 9bcf9b0 9c8dc4f Author: bchambers <bchamb...@google.com> Authored: Wed Jun 22 14:35:28 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Jun 22 14:35:2

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

2016-06-21 Thread bchambers
/diff/4840f527 Branch: refs/heads/python-sdk Commit: 4840f5275c569c190088179cb5dee6380ae641c9 Parents: f166b16 0608ad9 Author: bchambers <bchamb...@google.com> Authored: Tue Jun 21 15:20:27 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue Jun 21 15:20:2

[1/2] incubator-beam git commit: Fix AutoComplete example streaming configuration

2016-06-13 Thread bchambers
13 11:05:00 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon Jun 13 17:17:22 2016 -0700 -- .../java/org/apache/beam/examples/complete/AutoComplete.java | 6 +- 1 file changed, 5 insertions

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

2016-06-13 Thread bchambers
/diff/52276245 Branch: refs/heads/master Commit: 5227624526334ef18dc2109978f309af2a7d3521 Parents: 915bc19 e60e3e6 Author: bchambers <bchamb...@google.com> Authored: Mon Jun 13 17:17:27 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon Jun 13 17:17:2

[1/2] incubator-beam git commit: Make example AddTimestampFn range deterministic

2016-06-13 Thread bchambers
git-wip-us.apache.org/repos/asf/incubator-beam/diff/335202a0 Branch: refs/heads/master Commit: 335202a033ced6f30f1b0e5df9da047241abc750 Parents: 9e0d7d6 Author: Scott Wegner <sweg...@google.com> Authored: Thu Jun 9 11:31:23 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed

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

2016-06-13 Thread bchambers
/diff/e1b305ea Branch: refs/heads/master Commit: e1b305ea5d48e0f5f71ad0030c20c492b0f95c30 Parents: 9e0d7d6 335202a Author: bchambers <bchamb...@google.com> Authored: Mon Jun 13 11:21:31 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon Jun 13 11:21:3

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

2016-06-06 Thread bchambers
/diff/c0b67ab1 Branch: refs/heads/master Commit: c0b67ab1286893b9030d1ba5096b4ff3ab15f863 Parents: c2146b9 ebb6932 Author: bchambers <bchamb...@google.com> Authored: Mon Jun 6 10:23:21 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon Jun 6 10:23:2

[1/2] incubator-beam git commit: Return from awaitCompletion if Already Done

2016-06-06 Thread bchambers
nch: refs/heads/master Commit: ebb69320037fda48df5e6ca24ecc9415a4b2acb4 Parents: c2146b9 Author: Thomas Groh <tg...@users.noreply.github.com> Authored: Mon May 30 11:04:15 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon Jun 6 10:0

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

2016-05-25 Thread bchambers
/diff/a3fc40aa Branch: refs/heads/master Commit: a3fc40aa368de8bf5a775096abf0d392208f7061 Parents: 78c8c52 7abedfa Author: bchambers <bchamb...@google.com> Authored: Wed May 25 12:47:51 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed May 25 12:47:5

[1/2] incubator-beam git commit: Mark test PipelineOptions interface public

2016-05-25 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master 78c8c528e -> a3fc40aa3 Mark test PipelineOptions interface public Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7abedfae Tree:

[1/2] incubator-beam git commit: Evaluate display data from InProcessPipelineRunner

2016-05-24 Thread bchambers
mit: ac98c4a01f7e4b2bba3e99271b66e141e7555de8 Parents: 5535fc3 Author: Scott Wegner <sweg...@google.com> Authored: Mon May 23 14:29:33 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue May 24 14:1

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

2016-05-24 Thread bchambers
/diff/ffed1d47 Branch: refs/heads/master Commit: ffed1d4791f8260a60d4535d754e7e5cd69157d7 Parents: 5535fc3 ac98c4a Author: bchambers <bchamb...@google.com> Authored: Tue May 24 14:11:48 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue May 24 14:11:4

[1/2] incubator-beam git commit: Fix bug in PipelineOptions DisplayData serialization

2016-05-20 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master 4755c5a78 -> bb086b8d3 Fix bug in PipelineOptions DisplayData serialization PipelineOptions has been improved to generate display data to be consumed by a runner and used for display. However, there was a bug in the

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

2016-05-20 Thread bchambers
/diff/bb086b8d Branch: refs/heads/master Commit: bb086b8d367e2c360d965659b094035cf01d9959 Parents: 4755c5a 1e669c4 Author: bchambers <bchamb...@google.com> Authored: Fri May 20 17:51:15 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Fri May 20 17:51:1

[1/2] incubator-beam git commit: Add labels for SDK display data

2016-05-16 Thread bchambers
016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon May 16 12:44:14 2016 -0700 -- .../DataflowPipelineTranslatorTest.java | 2 + .../java/org/apache/beam/sdk/io/AvroIO.java | 28 + .../

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

2016-05-16 Thread bchambers
/diff/638cc207 Branch: refs/heads/master Commit: 638cc20719cb314d9e6b29fa79d45edcf4586dce Parents: 0f2e6f3 62f05d8 Author: bchambers <bchamb...@google.com> Authored: Mon May 16 12:44:19 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon May 16 12:44:1

[1/2] incubator-beam git commit: Validate display data on transform primitives

2016-05-16 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master 9b5cf3247 -> c0efe568e Validate display data on transform primitives Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6269b8fa Tree:

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

2016-05-16 Thread bchambers
/diff/c0efe568 Branch: refs/heads/master Commit: c0efe568e5291298c1394016a12e7979b37afc44 Parents: 9b5cf32 6269b8f Author: bchambers <bchamb...@google.com> Authored: Mon May 16 09:55:52 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon May 16 09:55:5

[3/9] incubator-beam git commit: Add display data for MapElements transform

2016-05-11 Thread bchambers
-us.apache.org/repos/asf/incubator-beam/diff/0dab643a Branch: refs/heads/master Commit: 0dab643ae3c7d275016f8b11e406af5d15e7f388 Parents: 9f6c27c Author: Scott Wegner <sweg...@google.com> Authored: Tue May 3 11:16:51 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue May 10 1

[2/9] incubator-beam git commit: Exclude default Window.allowedLateness display data

2016-05-11 Thread bchambers
-us.apache.org/repos/asf/incubator-beam/diff/d9355c28 Branch: refs/heads/master Commit: d9355c286fd7f3e6f7069b34172c32554b57bac8 Parents: ea8019e Author: Scott Wegner <sweg...@google.com> Authored: Fri May 6 16:03:12 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue May

[6/9] incubator-beam git commit: Fix Write transform primitive display data

2016-05-11 Thread bchambers
-us.apache.org/repos/asf/incubator-beam/diff/ea8019ec Branch: refs/heads/master Commit: ea8019eced55023e060fd6472b8d69d15bf73839 Parents: 007526f Author: Scott Wegner <sweg...@google.com> Authored: Fri May 6 11:40:47 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue May 10 1

[5/9] incubator-beam git commit: Exclude JsonIgnore PipelineOptions from DisplayData

2016-05-11 Thread bchambers
-us.apache.org/repos/asf/incubator-beam/diff/43085f7e Branch: refs/heads/master Commit: 43085f7e53e693202ab91768a7f3688fc54f24ee Parents: 0dab643 Author: Scott Wegner <sweg...@google.com> Authored: Tue May 3 14:10:59 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue May

[1/2] incubator-beam git commit: Remove ClassForDisplay helper type

2016-05-02 Thread bchambers
org/repos/asf/incubator-beam/diff/5eafdee5 Branch: refs/heads/master Commit: 5eafdee53cc49938921c5fbdf2bb81483f8773af Parents: 659cf2e Author: Scott Wegner <sweg...@google.com> Authored: Wed Apr 27 13:08:49 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon May 2 13:1

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

2016-05-02 Thread bchambers
/diff/659cf2ee Branch: refs/heads/master Commit: 659cf2ee0b32a4e49fac50999e886a8f052a3fb7 Parents: b9116ac 367f3ac Author: bchambers <bchamb...@google.com> Authored: Mon May 2 11:04:13 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon May 2 11:04:1

[1/2] incubator-beam git commit: Fix update sequence in InMemoryWatermarkManager

2016-05-02 Thread bchambers
mas Groh <tg...@google.com> Authored: Thu Apr 28 17:38:50 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon May 2 11:03:52 2016 -0700 -- .../direct/InMemoryWatermarkManager.java| 34

[3/3] incubator-beam git commit: This closes #247

2016-04-27 Thread bchambers
/diff/81bf4d98 Branch: refs/heads/master Commit: 81bf4d981a7d5d86955c02003fb615c4985552bb Parents: a9387fc 47c7abc Author: bchambers <bchamb...@google.com> Authored: Wed Apr 27 16:44:28 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Apr 27 16:44:2

[2/3] incubator-beam git commit: Reduce overloaded methods in DisplayData

2016-04-27 Thread bchambers
/47c7abca Branch: refs/heads/master Commit: 47c7abcacdd8ee1c14c2c8d94a263f96dfe5bf8d Parents: a9387fc Author: Scott Wegner <sweg...@google.com> Authored: Mon Apr 25 16:04:38 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Apr 27 16:44:1

[1/3] incubator-beam git commit: Refactor CommittedBundle in InProcessBundleFactory

2016-04-27 Thread bchambers
<tg...@google.com> Authored: Mon Apr 25 09:08:09 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Apr 27 10:13:15 2016 -0700 -- .../inprocess/InProcessBundleFactory.java | 82 1 f

[2/3] incubator-beam git commit: Add withElements to CommittedBundle

2016-04-27 Thread bchambers
/incubator-beam/tree/b108c66e Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b108c66e Branch: refs/heads/master Commit: b108c66e641f888a3f6732e581b860783dc3daf8 Parents: e4e7d2e Author: Thomas Groh <tg...@google.com> Authored: Mon Apr 25 09:09:15 2016 -0700 Committer: b

[3/3] incubator-beam git commit: This closes #231

2016-04-27 Thread bchambers
/diff/6914f2a1 Branch: refs/heads/master Commit: 6914f2a1d44ca810918592f45e63e09982101f32 Parents: e3105c8 b108c66 Author: bchambers <bchamb...@google.com> Authored: Wed Apr 27 10:13:21 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Apr 27 10:13:2

[4/4] incubator-beam git commit: This closes #241

2016-04-26 Thread bchambers
/diff/7dc1a404 Branch: refs/heads/master Commit: 7dc1a4047c8a145377c26ed73163a28f7b8835dd Parents: d299e2c c6690c1 Author: bchambers <bchamb...@google.com> Authored: Tue Apr 26 09:39:06 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue Apr 26 09:39:0

[3/4] incubator-beam git commit: Rename DisplayDataMatchers.includes to includesDisplayData to clarify usage

2016-04-26 Thread bchambers
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/582befdc Branch: refs/heads/master Commit: 582befdc8aed6dc62bf1d205749d7f46d7894f97 Parents: d299e2c Author: Scott Wegner <sweg...@google.com> Authored: Mon Apr 25 09:31:13 2016 -0700 Committer: bchambers <bchamb...@g

[2/4] incubator-beam git commit: Normalize comments to refer to 'display data' rather than 'display metadata'

2016-04-26 Thread bchambers
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9d45a4a1 Branch: refs/heads/master Commit: 9d45a4a11dcf66434c3d434d31900487471dcbe3 Parents: 582befd Author: Scott Wegner <sweg...@google.com> Authored: Mon Apr 25 09:34:58 2016 -0700 Committer: bchambers <bchamb...@g

[1/4] incubator-beam git commit: Add super.populateDisplayData() to standard implementations. The current super implementation is a no-op, but this is the recommended way to implement the pattern

2016-04-26 Thread bchambers
mit: c6690c18a64ec6c7971712ab43807b13c1849571 Parents: 9d45a4a Author: Scott Wegner <sweg...@google.com> Authored: Mon Apr 25 09:41:07 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue Apr 26 09:39:01 2016 -0700 -

[1/2] incubator-beam git commit: Add DirtyBit to represent whether Counters have been committed.

2016-04-26 Thread bchambers
ue Apr 19 18:21:40 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue Apr 26 08:24:30 2016 -0700 -- .../apache/beam/sdk/util/common/Counter.java| 459 --- .../beam/sdk/util/common/C

  1   2   >