You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/11/07 16:54:55 UTC
[39/50] [abbrv] beam git commit: This closes #4073
This closes #4073
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7550a589
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7550a589
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7550a589
Branch: refs/heads/mr-runner
Commit: 7550a589eec9abd81309326886349477ca2b59bc
Parents: 766b4f3 012c2e6
Author: Thomas Groh <tg...@google.com>
Authored: Mon Nov 6 16:06:57 2017 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Mon Nov 6 16:06:57 2017 -0800
----------------------------------------------------------------------
runners/java-fn-execution/pom.xml | 14 ------
.../runners/fnexecution/ServerFactoryTest.java | 45 ++++++++++++++-----
runners/pom.xml | 2 +-
sdks/java/fn-execution/pom.xml | 20 ++-------
.../org/apache/beam/harness/test/Consumer.java | 26 +++++++++++
.../org/apache/beam/harness/test/Supplier.java | 26 +++++++++++
.../apache/beam/harness/test/TestExecutors.java | 12 ++++-
.../beam/harness/test/TestExecutorsTest.java | 29 +++++++++---
.../apache/beam/harness/test/TestStreams.java | 35 ++++++++++++---
.../beam/harness/test/TestStreamsTest.java | 47 +++++++++++++++-----
.../apache/beam/fn/harness/FnHarnessTest.java | 4 +-
.../harness/data/BeamFnDataGrpcClientTest.java | 5 ++-
.../stream/BufferingStreamObserverTest.java | 2 +-
.../stream/DirectStreamObserverTest.java | 2 +-
sdks/java/pom.xml | 2 +-
15 files changed, 196 insertions(+), 75 deletions(-)
----------------------------------------------------------------------