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 <[email protected]> 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 [email protected].
