This is an automated email from the ASF dual-hosted git repository.
tgroh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 92540d0ecd98125e4f6fe13917dca46a77af52f0
Merge: 7cfb182 7594a8b
Author: Thomas Groh <tg...@users.noreply.github.com>
AuthorDate: Wed Dec 6 14:57:37 2017 -0800
Merge pull request #4201
Move StreamObserverFactory to java fn-execution
.../beam/sdk/fn}/stream/StreamObserverFactory.java | 83 ++++++++++++++--------
.../sdk/fn}/stream/StreamObserverFactoryTest.java | 39 +++++-----
.../java/org/apache/beam/fn/harness/FnHarness.java | 6 +-
.../fn/harness/control/BeamFnControlClient.java | 18 +++--
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 16 +++--
.../harness/state/BeamFnStateGrpcClientCache.java | 11 +--
.../stream/HarnessStreamObserverFactories.java | 57 +++++++++++++++
.../harness/control/BeamFnControlClientTest.java | 7 +-
.../fn/harness/data/BeamFnDataGrpcClientTest.java | 6 +-
.../state/BeamFnStateGrpcClientCacheTest.java | 7 +-
...ava => HarnessStreamObserverFactoriesTest.java} | 12 ++--
11 files changed, 170 insertions(+), 92 deletions(-)
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <commits@beam.apache.org>.
