Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id EC0B5200CC8 for ; Thu, 29 Jun 2017 20:40:10 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id EB570160BC6; Thu, 29 Jun 2017 18:40:10 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 3EB49160BED for ; Thu, 29 Jun 2017 20:40:10 +0200 (CEST) Received: (qmail 23700 invoked by uid 500); 29 Jun 2017 18:40:09 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 23656 invoked by uid 99); 29 Jun 2017 18:40:09 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 29 Jun 2017 18:40:09 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 3E4A0DFF9F; Thu, 29 Jun 2017 18:40:09 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 8bit From: jbonofre@apache.org To: commits@beam.apache.org Date: Thu, 29 Jun 2017 18:40:09 -0000 Message-Id: <78a5a3a5057b4e9ea57813a7d5bc765b@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [1/2] beam git commit: Define the projectId in the SpannerIO Read Test (utest, not itest) archived-at: Thu, 29 Jun 2017 18:40:11 -0000 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é Authored: Thu Jun 29 13:25:36 2017 +0200 Committer: Jean-Baptiste Onofré 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 tx = pipeline .apply("tx", SpannerIO.createTransaction() + .withProjectId("test") .withInstanceId("123") .withDatabaseId("aaa") .withServiceFactory(serviceFactory)); PCollection 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 two = pipeline.apply("read r", SpannerIO.read() + .withProjectId("test") .withInstanceId("123") .withDatabaseId("aaa") .withTimestamp(Timestamp.now())