beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [beam] 01/01: Merge pull request #4201
Date Wed, 06 Dec 2017 22:57:40 GMT
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 <tgroh@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>.

Mime
View raw message