Repository: beam Updated Branches: refs/heads/master bf5aa1bca -> ae3a75263
Define the projectId in the SpannerIO Read Test (utest, not itest) Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c6de4233 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c6de4233 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c6de4233 Branch: refs/heads/master Commit: c6de4233d1c1bc812ba2dea45291d9dcb40aa152 Parents: bf5aa1b Author: Jean-Baptiste Onofré <jbono...@apache.org> Authored: Thu Jun 29 13:25:36 2017 +0200 Committer: Jean-Baptiste Onofré <jbono...@apache.org> Committed: Thu Jun 29 20:39:39 2017 +0200 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/c6de4233/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java index e5d4e72..5ba2da0 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java @@ -150,6 +150,7 @@ public class SpannerIOReadTest implements Serializable { public void runQuery() throws Exception { SpannerIO.Read read = SpannerIO.read() + .withProjectId("test") .withInstanceId("123") .withDatabaseId("aaa") .withTimestamp(Timestamp.now()) @@ -176,6 +177,7 @@ public class SpannerIOReadTest implements Serializable { public void runRead() throws Exception { SpannerIO.Read read = SpannerIO.read() + .withProjectId("test") .withInstanceId("123") .withDatabaseId("aaa") .withTimestamp(Timestamp.now()) @@ -202,6 +204,7 @@ public class SpannerIOReadTest implements Serializable { public void runReadUsingIndex() throws Exception { SpannerIO.Read read = SpannerIO.read() + .withProjectId("test") .withInstanceId("123") .withDatabaseId("aaa") .withTimestamp(Timestamp.now()) @@ -232,11 +235,13 @@ public class SpannerIOReadTest implements Serializable { PCollectionView<Transaction> tx = pipeline .apply("tx", SpannerIO.createTransaction() + .withProjectId("test") .withInstanceId("123") .withDatabaseId("aaa") .withServiceFactory(serviceFactory)); PCollection<Struct> one = pipeline.apply("read q", SpannerIO.read() + .withProjectId("test") .withInstanceId("123") .withDatabaseId("aaa") .withTimestamp(Timestamp.now()) @@ -244,6 +249,7 @@ public class SpannerIOReadTest implements Serializable { .withServiceFactory(serviceFactory) .withTransaction(tx)); PCollection<Struct> two = pipeline.apply("read r", SpannerIO.read() + .withProjectId("test") .withInstanceId("123") .withDatabaseId("aaa") .withTimestamp(Timestamp.now())