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

Posted to commits@beam.apache.org by lc...@apache.org on 2020/01/10 17:51:02 UTC

[beam] branch master updated (ac999d9 -> 1329c26)

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from ac999d9  Merge pull request #10508 from suztomo/google-auth-library-oauth2-http
     add 1329c26  [BEAM-8624] Implement Worker Status FnService in Dataflow runner (#10115)

No new revisions were added by this update.

Summary of changes:
 .../fn-execution/src/main/proto/beam_fn_api.proto  |  29 +++
 .../status/BeamWorkerStatusGrpcService.java        | 223 +++++++++++++++++++++
 .../fnexecution/status/WorkerStatusClient.java     | 165 +++++++++++++++
 .../runners/fnexecution/status}/package-info.java  |   4 +-
 .../status/BeamWorkerStatusGrpcServiceTest.java    | 192 ++++++++++++++++++
 .../fnexecution/status/WorkerStatusClientTest.java |  91 +++++++++
 6 files changed, 702 insertions(+), 2 deletions(-)
 create mode 100644 runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/status/BeamWorkerStatusGrpcService.java
 create mode 100644 runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/status/WorkerStatusClient.java
 copy {sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf => runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/status}/package-info.java (90%)
 create mode 100644 runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/status/BeamWorkerStatusGrpcServiceTest.java
 create mode 100644 runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/status/WorkerStatusClientTest.java