{
private DataTransferServiceBlockingStub(
@@ -1405,93 +1169,47 @@ protected DataTransferServiceBlockingStub build(
return new DataTransferServiceBlockingStub(channel, callOptions);
}
- /**
- *
- *
- *
- * Retrieves a supported data source and returns its settings,
- * which can be used for UI rendering.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.DataSource getDataSource(
com.google.cloud.bigquery.datatransfer.v1.GetDataSourceRequest request) {
return blockingUnaryCall(getChannel(), getGetDataSourceMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Lists supported data sources and returns their settings,
- * which can be used for UI rendering.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesResponse listDataSources(
com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesRequest request) {
return blockingUnaryCall(getChannel(), getListDataSourcesMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Creates a new data transfer configuration.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.TransferConfig createTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.CreateTransferConfigRequest request) {
return blockingUnaryCall(
getChannel(), getCreateTransferConfigMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Updates a data transfer configuration.
- * All fields must be set, even if they are not updated.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.TransferConfig updateTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.UpdateTransferConfigRequest request) {
return blockingUnaryCall(
getChannel(), getUpdateTransferConfigMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Deletes a data transfer configuration,
- * including any associated transfer runs and logs.
- *
- */
+ /** */
public com.google.protobuf.Empty deleteTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.DeleteTransferConfigRequest request) {
return blockingUnaryCall(
getChannel(), getDeleteTransferConfigMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Returns information about a data transfer config.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.TransferConfig getTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.GetTransferConfigRequest request) {
return blockingUnaryCall(
getChannel(), getGetTransferConfigMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Returns information about all data transfers in the project.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsResponse
listTransferConfigs(
com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsRequest request) {
@@ -1499,17 +1217,7 @@ public com.google.cloud.bigquery.datatransfer.v1.TransferConfig getTransferConfi
getChannel(), getListTransferConfigsMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Creates transfer runs for a time range [start_time, end_time].
- * For each date - or whatever granularity the data source supports - in the
- * range, one transfer run is created.
- * Note that runs are created per UTC time in the time range.
- * DEPRECATED: use StartManualTransferRuns instead.
- *
- */
+ /** */
@java.lang.Deprecated
public com.google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsResponse
scheduleTransferRuns(
@@ -1518,16 +1226,7 @@ public com.google.cloud.bigquery.datatransfer.v1.TransferConfig getTransferConfi
getChannel(), getScheduleTransferRunsMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Start manual transfer runs to be executed now with schedule_time equal to
- * current time. The transfer runs can be created for a time range where the
- * run_time is between start_time (inclusive) and end_time (exclusive), or for
- * a specific run_time.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsResponse
startManualTransferRuns(
com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsRequest request) {
@@ -1535,85 +1234,41 @@ public com.google.cloud.bigquery.datatransfer.v1.TransferConfig getTransferConfi
getChannel(), getStartManualTransferRunsMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Returns information about the particular transfer run.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.TransferRun getTransferRun(
com.google.cloud.bigquery.datatransfer.v1.GetTransferRunRequest request) {
return blockingUnaryCall(getChannel(), getGetTransferRunMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Deletes the specified transfer run.
- *
- */
+ /** */
public com.google.protobuf.Empty deleteTransferRun(
com.google.cloud.bigquery.datatransfer.v1.DeleteTransferRunRequest request) {
return blockingUnaryCall(
getChannel(), getDeleteTransferRunMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Returns information about running and completed jobs.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsResponse listTransferRuns(
com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest request) {
return blockingUnaryCall(
getChannel(), getListTransferRunsMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Returns user facing log messages for the data transfer run.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsResponse listTransferLogs(
com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsRequest request) {
return blockingUnaryCall(
getChannel(), getListTransferLogsMethod(), getCallOptions(), request);
}
- /**
- *
- *
- *
- * Returns true if valid credentials exist for the given data source and
- * requesting user.
- * Some data sources doesn't support service account, so we need to talk to
- * them on behalf of the end user. This API just checks whether we have OAuth
- * token for the particular user, which is a pre-requisite before user can
- * create a transfer config.
- *
- */
+ /** */
public com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsResponse checkValidCreds(
com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsRequest request) {
return blockingUnaryCall(getChannel(), getCheckValidCredsMethod(), getCallOptions(), request);
}
}
- /**
- *
- *
- *
- * The Google BigQuery Data Transfer Service API enables BigQuery users to
- * configure the transfer of their data from other Google Products into
- * BigQuery. This service contains methods that are end user exposed. It backs
- * up the frontend.
- *
- */
+ /** */
public static final class DataTransferServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private DataTransferServiceFutureStub(
@@ -1627,14 +1282,7 @@ protected DataTransferServiceFutureStub build(
return new DataTransferServiceFutureStub(channel, callOptions);
}
- /**
- *
- *
- *
- * Retrieves a supported data source and returns its settings,
- * which can be used for UI rendering.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.DataSource>
getDataSource(com.google.cloud.bigquery.datatransfer.v1.GetDataSourceRequest request) {
@@ -1642,14 +1290,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getGetDataSourceMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Lists supported data sources and returns their settings,
- * which can be used for UI rendering.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesResponse>
listDataSources(com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesRequest request) {
@@ -1657,13 +1298,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getListDataSourcesMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Creates a new data transfer configuration.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>
createTransferConfig(
@@ -1672,14 +1307,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getCreateTransferConfigMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Updates a data transfer configuration.
- * All fields must be set, even if they are not updated.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>
updateTransferConfig(
@@ -1688,14 +1316,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getUpdateTransferConfigMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Deletes a data transfer configuration,
- * including any associated transfer runs and logs.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture
deleteTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.DeleteTransferConfigRequest request) {
@@ -1703,13 +1324,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getDeleteTransferConfigMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Returns information about a data transfer config.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>
getTransferConfig(
@@ -1718,13 +1333,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getGetTransferConfigMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Returns information about all data transfers in the project.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsResponse>
listTransferConfigs(
@@ -1733,17 +1342,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getListTransferConfigsMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Creates transfer runs for a time range [start_time, end_time].
- * For each date - or whatever granularity the data source supports - in the
- * range, one transfer run is created.
- * Note that runs are created per UTC time in the time range.
- * DEPRECATED: use StartManualTransferRuns instead.
- *
- */
+ /** */
@java.lang.Deprecated
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsResponse>
@@ -1753,16 +1352,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getScheduleTransferRunsMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Start manual transfer runs to be executed now with schedule_time equal to
- * current time. The transfer runs can be created for a time range where the
- * run_time is between start_time (inclusive) and end_time (exclusive), or for
- * a specific run_time.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsResponse>
startManualTransferRuns(
@@ -1771,13 +1361,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getStartManualTransferRunsMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Returns information about the particular transfer run.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.TransferRun>
getTransferRun(com.google.cloud.bigquery.datatransfer.v1.GetTransferRunRequest request) {
@@ -1785,13 +1369,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getGetTransferRunMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Deletes the specified transfer run.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture
deleteTransferRun(
com.google.cloud.bigquery.datatransfer.v1.DeleteTransferRunRequest request) {
@@ -1799,13 +1377,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getDeleteTransferRunMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Returns information about running and completed jobs.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsResponse>
listTransferRuns(
@@ -1814,13 +1386,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getListTransferRunsMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Returns user facing log messages for the data transfer run.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsResponse>
listTransferLogs(
@@ -1829,18 +1395,7 @@ protected DataTransferServiceFutureStub build(
getChannel().newCall(getListTransferLogsMethod(), getCallOptions()), request);
}
- /**
- *
- *
- *
- * Returns true if valid credentials exist for the given data source and
- * requesting user.
- * Some data sources doesn't support service account, so we need to talk to
- * them on behalf of the end user. This API just checks whether we have OAuth
- * token for the particular user, which is a pre-requisite before user can
- * create a transfer config.
- *
- */
+ /** */
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsResponse>
checkValidCreds(com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsRequest request) {
diff --git a/synth.metadata b/synth.metadata
index 7920d9f4..5df9590f 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -11,15 +11,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-bigquerydatatransfer.git",
- "sha": "c1d4e4729513693bc05d3ea77b8cc63df0dbc22e"
+ "sha": "10ca24cea52ba52f7e3f22282eb0014b1300fe98"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "96ef637adf148d54236ad83fefa30c7f75f29737",
- "internalRef": "325052820"
+ "sha": "b11a87f3b54be3a5e42c15020ee1e0781f86da90",
+ "internalRef": "344134135"
}
},
{
From a9e8e9705325e900e5f81ff957e7785aa0bb6a70 Mon Sep 17 00:00:00 2001
From: Praful Makani
Date: Tue, 1 Dec 2020 00:49:39 +0530
Subject: [PATCH 10/13] refactor(samples): updates params and comments (#543)
---
.../bigquerydatatransfer/CreateAdManagerTransfer.java | 4 ++--
.../com/example/bigquerydatatransfer/CreateAdsTransfer.java | 6 +++---
.../bigquerydatatransfer/CreateCampaignmanagerTransfer.java | 4 ++--
.../example/bigquerydatatransfer/CreatePlayTransfer.java | 1 -
.../bigquerydatatransfer/CreateYoutubeChannelTransfer.java | 1 -
.../CreateYoutubeContentOwnerTransfer.java | 1 -
6 files changed, 7 insertions(+), 10 deletions(-)
diff --git a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateAdManagerTransfer.java b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateAdManagerTransfer.java
index ef46c4b1..e4bbd2bd 100644
--- a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateAdManagerTransfer.java
+++ b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateAdManagerTransfer.java
@@ -36,7 +36,8 @@ public static void main(String[] args) throws IOException {
final String projectId = "MY_PROJECT_ID";
String datasetId = "MY_DATASET_ID";
String bucket = "gs://cloud-sample-data";
- String networkCode = "MY_NETWORK_CODE";
+ // the network_code can only be digits with length 1 to 15
+ String networkCode = "12345678";
Map params = new HashMap<>();
params.put("bucket", Value.newBuilder().setStringValue(bucket).build());
params.put("network_code", Value.newBuilder().setStringValue(networkCode).build());
@@ -46,7 +47,6 @@ public static void main(String[] args) throws IOException {
.setDisplayName("Your Ad Manager Config Name")
.setDataSourceId("dfp_dt")
.setParams(Struct.newBuilder().putAllFields(params).build())
- .setSchedule("every 24 hours")
.build();
createAdManagerTransfer(projectId, transferConfig);
}
diff --git a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateAdsTransfer.java b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateAdsTransfer.java
index 02ed0971..af8a7364 100644
--- a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateAdsTransfer.java
+++ b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateAdsTransfer.java
@@ -35,8 +35,9 @@ public static void main(String[] args) throws IOException {
// TODO(developer): Replace these variables before running the sample.
final String projectId = "MY_PROJECT_ID";
String datasetId = "MY_DATASET_ID";
- String customerId = "MY_CUSTOMER_ID";
- String refreshWindow = "MY_REFRESH_WINDOW";
+ // the customer_id only allows digits and hyphen ('-').
+ String customerId = "012-345-6789";
+ String refreshWindow = "100";
Map params = new HashMap<>();
params.put("customer_id", Value.newBuilder().setStringValue(customerId).build());
params.put("refreshWindow", Value.newBuilder().setStringValue(refreshWindow).build());
@@ -46,7 +47,6 @@ public static void main(String[] args) throws IOException {
.setDisplayName("Your Ads Transfer Config Name")
.setDataSourceId("adwords")
.setParams(Struct.newBuilder().putAllFields(params).build())
- .setSchedule("every 24 hours")
.build();
createAdsTransfer(projectId, transferConfig);
}
diff --git a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateCampaignmanagerTransfer.java b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateCampaignmanagerTransfer.java
index 5c6da22e..9aa617ff 100644
--- a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateCampaignmanagerTransfer.java
+++ b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateCampaignmanagerTransfer.java
@@ -36,7 +36,8 @@ public static void main(String[] args) throws IOException {
final String projectId = "MY_PROJECT_ID";
String datasetId = "MY_DATASET_ID";
String bucket = "gs://cloud-sample-data";
- String networkId = "MY_DOUBLE_CLICK_ID";
+ // the network_id only allows digits
+ String networkId = "7878";
String fileNamePrefix = "test_";
Map params = new HashMap<>();
params.put("bucket", Value.newBuilder().setStringValue(bucket).build());
@@ -48,7 +49,6 @@ public static void main(String[] args) throws IOException {
.setDisplayName("Your Campaignmanager Config Name")
.setDataSourceId("dcm_dt")
.setParams(Struct.newBuilder().putAllFields(params).build())
- .setSchedule("every 24 hours")
.build();
createCampaignmanagerTransfer(projectId, transferConfig);
}
diff --git a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreatePlayTransfer.java b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreatePlayTransfer.java
index d0d15812..51783130 100644
--- a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreatePlayTransfer.java
+++ b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreatePlayTransfer.java
@@ -46,7 +46,6 @@ public static void main(String[] args) throws IOException {
.setDisplayName("Your Play Config Name")
.setDataSourceId("play")
.setParams(Struct.newBuilder().putAllFields(params).build())
- .setSchedule("every 24 hours")
.build();
createPlayTransfer(projectId, transferConfig);
}
diff --git a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateYoutubeChannelTransfer.java b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateYoutubeChannelTransfer.java
index 3a62a0f3..8dcb26bb 100644
--- a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateYoutubeChannelTransfer.java
+++ b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateYoutubeChannelTransfer.java
@@ -44,7 +44,6 @@ public static void main(String[] args) throws IOException {
.setDisplayName("Your Youtube Channel Config Name")
.setDataSourceId("youtube_channel")
.setParams(Struct.newBuilder().putAllFields(params).build())
- .setSchedule("every 24 hours")
.build();
createYoutubeChannelTransfer(projectId, transferConfig);
}
diff --git a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateYoutubeContentOwnerTransfer.java b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateYoutubeContentOwnerTransfer.java
index 6d2ee2e0..d99ffa52 100644
--- a/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateYoutubeContentOwnerTransfer.java
+++ b/samples/snippets/src/main/java/com/example/bigquerydatatransfer/CreateYoutubeContentOwnerTransfer.java
@@ -46,7 +46,6 @@ public static void main(String[] args) throws IOException {
.setDisplayName("Your Youtube Owner Channel Config Name")
.setDataSourceId("youtube_content_owner")
.setParams(Struct.newBuilder().putAllFields(params).build())
- .setSchedule("every 24 hours")
.build();
createYoutubeContentOwnerTransfer(projectId, transferConfig);
}
From c42c3aa06bafeaf6d57440ce6a32b1542cb28a0e Mon Sep 17 00:00:00 2001
From: WhiteSource Renovate
Date: Wed, 2 Dec 2020 17:46:41 +0100
Subject: [PATCH 11/13] deps: update dependency
com.google.cloud:google-cloud-pubsub to v1.110.0 (#547)
---
samples/install-without-bom/pom.xml | 2 +-
samples/snapshot/pom.xml | 2 +-
samples/snippets/pom.xml | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/samples/install-without-bom/pom.xml b/samples/install-without-bom/pom.xml
index 99760cba..77dcb152 100644
--- a/samples/install-without-bom/pom.xml
+++ b/samples/install-without-bom/pom.xml
@@ -59,7 +59,7 @@
com.google.cloud
google-cloud-pubsub
- 1.109.0
+ 1.110.0
test