You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/06/28 03:16:53 UTC
[4/4] beam git commit: This closes #3395: [BEAM-1542] Cloud Spanner
Source
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 <ki...@google.com>
Authored: Tue Jun 27 18:43:06 2017 -0700
Committer: Eugene Kirpichov <ki...@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(-)
----------------------------------------------------------------------