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 7b30ca64b3ef312610f2b78008ab82f62697fd30
Merge: a716332 d1c80ef
Author: Thomas Groh <tg...@users.noreply.github.com>
AuthorDate: Fri Apr 13 15:28:35 2018 -0700

    Merge pull request #5008: Use typed client pool sinks and sources
    
    [BEAM-3994]

 .../fnexecution/control/ControlClientPool.java     | 23 ++++----
 .../control/FnApiControlClientPoolService.java     | 14 +++--
 .../control/QueueControlClientPool.java            | 62 ++++++++++++++++++++++
 .../control/SdkHarnessClientControlService.java    | 13 ++---
 .../runners/fnexecution/InProcessSdkHarness.java   | 13 ++---
 .../control/FnApiControlClientPoolServiceTest.java | 11 ++--
 .../fnexecution/control/RemoteExecutionTest.java   |  8 ++-
 .../fn/function}/CloseableThrowingConsumer.java    |  3 +-
 .../beam/sdk/fn/function}/ThrowingBiConsumer.java  |  2 +-
 .../beam/sdk/fn/function}/ThrowingBiFunction.java  |  2 +-
 .../beam/sdk/fn/function}/ThrowingConsumer.java    |  3 +-
 .../beam/sdk/fn/function}/ThrowingFunction.java    |  2 +-
 .../beam/sdk/fn/function}/ThrowingRunnable.java    |  2 +-
 .../apache/beam/sdk/fn/function}/package-info.java |  6 +--
 .../beam/fn/harness/BeamFnDataReadRunner.java      |  2 +-
 .../beam/fn/harness/BeamFnDataWriteRunner.java     |  2 +-
 .../beam/fn/harness/BoundedSourceRunner.java       |  2 +-
 .../org/apache/beam/fn/harness/FlattenRunner.java  |  2 +-
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |  2 +-
 .../java/org/apache/beam/fn/harness/FnHarness.java |  2 +-
 .../org/apache/beam/fn/harness/MapFnRunner.java    |  4 +-
 .../beam/fn/harness/PTransformRunnerFactory.java   |  2 +-
 .../beam/fn/harness/WindowMappingFnRunner.java     |  2 +-
 .../fn/harness/control/BeamFnControlClient.java    |  2 +-
 .../fn/harness/control/ProcessBundleHandler.java   |  2 +-
 .../beam/fn/harness/BeamFnDataReadRunnerTest.java  |  2 +-
 .../beam/fn/harness/BeamFnDataWriteRunnerTest.java |  2 +-
 .../beam/fn/harness/BoundedSourceRunnerTest.java   |  2 +-
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       |  2 +-
 .../apache/beam/fn/harness/MapFnRunnerTest.java    |  4 +-
 .../beam/fn/harness/WindowMappingFnRunnerTest.java |  2 +-
 .../harness/control/BeamFnControlClientTest.java   |  2 +-
 .../harness/control/ProcessBundleHandlerTest.java  |  4 +-
 33 files changed, 134 insertions(+), 74 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
tg...@apache.org.

Reply via email to