You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by tg...@apache.org on 2017/12/06 22:57:40 UTC

[beam] 01/01: Merge pull request #4201

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" <co...@beam.apache.org>.