beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbono...@apache.org
Subject [1/2] beam git commit: Define the projectId in the SpannerIO Read Test (utest, not itest)
Date Thu, 29 Jun 2017 18:40:09 GMT
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é <jbonofre@apache.org>
Authored: Thu Jun 29 13:25:36 2017 +0200
Committer: Jean-Baptiste Onofré <jbonofre@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())


Mime
View raw message