Repository: beam Updated Branches: refs/heads/master 245d77338 -> ec052bb44
Sets user agent in BigTableIO.Read.getBigTableService(). Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6b25948b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6b25948b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6b25948b Branch: refs/heads/master Commit: 6b25948b4f56e4d45e1f9e03eb19c6077413a80e Parents: 245d773 Author: [email protected] <[email protected]> Authored: Mon Oct 16 00:50:03 2017 -0700 Committer: [email protected] <[email protected]> Committed: Mon Oct 16 13:14:17 2017 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/6b25948b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java index 47efa08..ba6c0b6 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java @@ -415,6 +415,7 @@ public class BigtableIO { return getBigtableService(); } BigtableOptions.Builder clonedOptions = getBigtableOptions().toBuilder(); + clonedOptions.setUserAgent(pipelineOptions.getUserAgent()); if (getBigtableOptions().getCredentialOptions() .getCredentialType() == CredentialType.DefaultCredentials) { clonedOptions.setCredentialOptions(
