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/mr-runner Commit: 3dfcb44475c92cea85cdceebe1d0cce0ca0e31cf Parents: 35952f6 227801b Author: chamik...@google.com <chamik...@google.com> Authored: Mon Nov 6 17:34:54 2017 -0800 Committer: chamik...@google.com <chamik...@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(-) ----------------------------------------------------------------------
