You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ch...@apache.org on 2018/10/25 21:02:49 UTC
[beam] 01/01: Merge pull request #6478: [BEAM-5445] [BEAM-4796]
[BEAM-3516] SpannerIO: Improve performance and documentation. Adds
streaming support
This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 0c980532b0c28029a01dfc7eb93fa7f2d8b06272
Merge: f965ebf 1f674863
Author: Chamikara Jayalath <ch...@google.com>
AuthorDate: Thu Oct 25 14:02:40 2018 -0700
Merge pull request #6478: [BEAM-5445] [BEAM-4796] [BEAM-3516] SpannerIO: Improve performance and documentation. Adds streaming support
.../beam/sdk/io/gcp/spanner/MutationGroup.java | 8 +
.../sdk/io/gcp/spanner/MutationGroupEncoder.java | 691 -------------------
.../sdk/io/gcp/spanner/MutationKeyEncoder.java | 203 ++++++
.../sdk/io/gcp/spanner/SerializedMutation.java | 35 -
.../io/gcp/spanner/SerializedMutationCoder.java | 57 --
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 551 +++++++++------
.../sdk/io/gcp/spanner/SpannerWriteResult.java | 6 +-
.../io/gcp/spanner/MutationGroupEncoderTest.java | 756 ---------------------
.../sdk/io/gcp/spanner/MutationKeyEncoderTest.java | 449 ++++++++++++
.../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 659 +++++++++++-------
10 files changed, 1430 insertions(+), 1985 deletions(-)