This is an automated email from the ASF dual-hosted git repository.
scwhittle pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from fc0617571ed Bump cloud.google.com/go/spanner from 1.82.0 to 1.83.0 in
/sdks (#35508)
add 13e5921eb34 [Dataflow Streaming] Modify AbstractWindmillStream to
separate logical stream from physical streams. (#35327)
No new revisions were added by this update.
Summary of changes:
.../windmill/client/AbstractWindmillStream.java | 234 +++++++++----
.../client/grpc/AppendableInputStream.java | 10 +-
.../windmill/client/grpc/GrpcCommitWorkStream.java | 152 +++++----
.../client/grpc/GrpcDirectGetWorkStream.java | 72 ++--
.../windmill/client/grpc/GrpcGetDataStream.java | 278 ++++++++++------
.../client/grpc/GrpcGetDataStreamRequests.java | 22 +-
.../windmill/client/grpc/GrpcGetWorkStream.java | 59 ++--
.../client/grpc/GrpcGetWorkerMetadataStream.java | 38 ++-
.../grpc/observers/StreamObserverFactory.java | 7 +
.../worker/StreamingDataflowWorkerTest.java | 4 +-
.../client/AbstractWindmillStreamTest.java | 28 +-
.../windmill/client/WindmillStreamPoolTest.java | 6 +-
.../client/grpc/FakeWindmillGrpcService.java | 129 +++++++
.../client/grpc/GrpcCommitWorkStreamTest.java | 369 +++++++++++++++------
.../client/grpc/GrpcDirectGetWorkStreamTest.java | 6 +-
.../client/grpc/GrpcGetDataStreamRequestsTest.java | 16 +-
.../client/grpc/GrpcGetDataStreamTest.java | 206 +++++++-----
.../grpc/GrpcGetWorkerMetadataStreamTest.java | 8 +-
.../client/grpc/GrpcWindmillServerTest.java | 9 +-
19 files changed, 1143 insertions(+), 510 deletions(-)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/FakeWindmillGrpcService.java
