You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2017/06/29 18:40:09 UTC
[1/2] beam git commit: Define the projectId in the SpannerIO Read
Test (utest, not itest)
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é <jb...@apache.org>
Authored: Thu Jun 29 13:25:36 2017 +0200
Committer: Jean-Baptiste Onofré <jb...@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())
[2/2] beam git commit: This closes #3471
Posted by jb...@apache.org.
This closes #3471
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ae3a7526
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ae3a7526
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ae3a7526
Branch: refs/heads/master
Commit: ae3a75263c3fc06e0dc16bc6964e199df167e32f
Parents: bf5aa1b c6de423
Author: Jean-Baptiste Onofré <jb...@apache.org>
Authored: Thu Jun 29 20:39:59 2017 +0200
Committer: Jean-Baptiste Onofré <jb...@apache.org>
Committed: Thu Jun 29 20:39:59 2017 +0200
----------------------------------------------------------------------
.../org/apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------