import com.google.api.gax.rpc.ApiException;
import com.google.cloud.bigquery.datatransfer.v1.DataTransferServiceClient;
import com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest;
import java.io.IOException;
// Sample to get run history from transfer config.
public class RunHistory {
public static void main(String[] args) throws IOException {
// TODO(developer): Replace these variables before running the sample.
String configId = "MY_CONFIG_ID";
// i.e projects/{project_id}/transferConfigs/{config_id}` or
// `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}`
runHistory(configId);
}
public static void runHistory(String configId) throws IOException {
try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
ListTransferRunsRequest request =
ListTransferRunsRequest.newBuilder().setParent(configId).build();
dataTransferServiceClient
.listTransferRuns(request)
.iterateAll()
.forEach(run -> System.out.print("Success! Run ID :" + run.getName() + "\n"));
} catch (ApiException ex) {
System.out.println("Run history not found due to error." + ex.toString());
}
}
}
