This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 93be6ae [BEAM-7736] Free worker when work is skipped
add 3f3e93d Done notifications for BigtableIO.Write
add 5fb21e3 Merge pull request #7805: [BEAM-3061] Done notifications for
BigtableIO.Write
No new revisions were added by this update.
Summary of changes:
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 256 ++++++++++++++-------
.../sdk/io/gcp/bigtable/BigtableWriteResult.java | 22 +-
.../io/gcp/bigtable/BigtableWriteResultCoder.java | 55 +++++
.../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 149 +++++++++++-
4 files changed, 382 insertions(+), 100 deletions(-)
copy
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/RemoteInputDestination.java
=>
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteResult.java
(58%)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteResultCoder.java
