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

Posted to commits@beam.apache.org by ie...@apache.org on 2019/07/15 15:27:21 UTC

[beam] branch master updated (93be6ae -> 5fb21e3)

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