This closes #3395: [BEAM-1542] Cloud Spanner Source
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e5929bd1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e5929bd1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e5929bd1 Branch: refs/heads/master Commit: e5929bd1337747b9c3971caf12f425f7e84750ad Parents: 0b19fb4 a21a6d7 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Tue Jun 27 18:43:06 2017 -0700 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Tue Jun 27 18:43:06 2017 -0700 ---------------------------------------------------------------------- pom.xml | 14 +- sdks/java/io/google-cloud-platform/pom.xml | 16 +- .../sdk/io/gcp/spanner/AbstractSpannerFn.java | 58 ++ .../sdk/io/gcp/spanner/CreateTransactionFn.java | 51 ++ .../sdk/io/gcp/spanner/NaiveSpannerReadFn.java | 65 ++ .../beam/sdk/io/gcp/spanner/SpannerConfig.java | 137 +++++ .../beam/sdk/io/gcp/spanner/SpannerIO.java | 604 +++++++++++++------ .../sdk/io/gcp/spanner/SpannerWriteGroupFn.java | 125 ++++ .../beam/sdk/io/gcp/spanner/Transaction.java | 33 + .../beam/sdk/io/gcp/GcpApiSurfaceTest.java | 10 + .../sdk/io/gcp/spanner/FakeServiceFactory.java | 82 +++ .../sdk/io/gcp/spanner/SpannerIOReadTest.java | 275 +++++++++ .../beam/sdk/io/gcp/spanner/SpannerIOTest.java | 317 ---------- .../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 258 ++++++++ .../beam/sdk/io/gcp/spanner/SpannerReadIT.java | 169 ++++++ .../beam/sdk/io/gcp/spanner/SpannerWriteIT.java | 2 +- 16 files changed, 1695 insertions(+), 521 deletions(-) ----------------------------------------------------------------------