This closes #3241
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c7a37b4b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c7a37b4b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c7a37b4b Branch: refs/heads/master Commit: c7a37b4b183995448b005229c6d0e50fe3e34ad2 Parents: 99e60f4 a251d01 Author: Dan Halperin <[email protected]> Authored: Fri May 26 13:48:32 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Fri May 26 13:48:32 2017 -0700 ---------------------------------------------------------------------- pom.xml | 42 ++-- sdks/java/io/google-cloud-platform/pom.xml | 20 +- .../io/gcp/spanner/MutationSizeEstimator.java | 98 ++++++++ .../beam/sdk/io/gcp/spanner/SpannerIO.java | 182 +++++++++----- .../gcp/spanner/MutationSizeEstimatorTest.java | 138 +++++++++++ .../beam/sdk/io/gcp/spanner/SpannerIOTest.java | 244 +++++++++++++++++++ .../beam/sdk/io/gcp/spanner/SpannerWriteIT.java | 159 ++++++++++++ 7 files changed, 808 insertions(+), 75 deletions(-) ----------------------------------------------------------------------
