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 2017/11/07 01:35:28 UTC
[2/2] beam git commit: This closes #3729
This closes #3729
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3dfcb444
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3dfcb444
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3dfcb444
Branch: refs/heads/master
Commit: 3dfcb44475c92cea85cdceebe1d0cce0ca0e31cf
Parents: 35952f6 227801b
Author: chamikara@google.com <ch...@google.com>
Authored: Mon Nov 6 17:34:54 2017 -0800
Committer: chamikara@google.com <ch...@google.com>
Committed: Mon Nov 6 17:34:54 2017 -0800
----------------------------------------------------------------------
.../sdk/io/gcp/spanner/NaiveSpannerReadFn.java | 1 +
.../sdk/io/gcp/spanner/SerializedMutation.java | 35 ++
.../io/gcp/spanner/SerializedMutationCoder.java | 60 +++
.../beam/sdk/io/gcp/spanner/SpannerIO.java | 309 ++++++++++++-
.../sdk/io/gcp/spanner/SpannerWriteGroupFn.java | 133 ------
.../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 447 ++++++++++++++-----
.../beam/sdk/io/gcp/spanner/SpannerWriteIT.java | 5 +-
7 files changed, 746 insertions(+), 244 deletions(-)
----------------------------------------------------------------------