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
