This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 3a87bba7334 Bump cloud.google.com/go/storage from 1.32.0 to 1.33.0 in
/sdks (#28366)
add 9b8644d056e add getworkermetadata streaming rpc (#27767)
No new revisions were added by this update.
Summary of changes:
.../google-cloud-dataflow-java/worker/build.gradle | 135 +++++----
.../worker/windmill/AbstractWindmillStream.java | 17 +-
.../windmill/ForwardingClientResponseObserver.java | 14 +-
.../worker/windmill/StreamObserverFactory.java | 18 +-
.../worker/windmill/WindmillEndpoints.java | 221 ++++++++++++++
.../worker/windmill/WindmillServiceAddress.java | 44 ++-
.../dataflow/worker/windmill/WindmillStream.java | 4 +
.../windmill/grpcclient/GrpcCommitWorkStream.java | 31 +-
.../windmill/grpcclient/GrpcGetDataStream.java | 41 ++-
.../windmill/grpcclient/GrpcGetWorkStream.java | 25 +-
.../grpcclient/GrpcGetWorkerMetadataStream.java | 170 +++++++++++
.../windmill/grpcclient/GrpcWindmillServer.java | 40 ++-
.../GrpcGetWorkerMetadataStreamTest.java | 328 +++++++++++++++++++++
.../worker/windmill/src/main/proto/windmill.proto | 11 +-
.../windmill/src/main/proto/windmill_service.proto | 2 +-
15 files changed, 922 insertions(+), 179 deletions(-)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/WindmillEndpoints.java
copy
sdks/java/core/src/test/java/org/apache/beam/sdk/coders/AvroCoderTestPojo.java
=>
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/WindmillServiceAddress.java
(52%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/grpcclient/GrpcGetWorkerMetadataStream.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/grpcclient/GrpcGetWorkerMetadataStreamTest.java
