Repository: beam Updated Branches: refs/heads/release-2.2.0 e7a8620e0 -> 09431daeb
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/ba9d1f99 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ba9d1f99 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ba9d1f99 Branch: refs/heads/release-2.2.0 Commit: ba9d1f99b78be9725c5b0ec29b703b777d4278d7 Parents: e7a8620 Author: [email protected] <[email protected]> Authored: Mon Oct 16 00:50:03 2017 -0700 Committer: [email protected] <[email protected]> Committed: Tue Oct 17 18:59:38 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/ba9d1f99/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(
