Class ExecutionsClient (0.43.0)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
ExecutionNamename=ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]");
Executionresponse=executionsClient.getExecution(name);
}

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
ExecutionsSettingsexecutionsSettings=
ExecutionsSettings.newBuilder()
.setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
.build();
ExecutionsClientexecutionsClient=ExecutionsClient.create(executionsSettings);

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
ExecutionsSettingsexecutionsSettings=
ExecutionsSettings.newBuilder().setEndpoint(myEndpoint).build();
ExecutionsClientexecutionsClient=ExecutionsClient.create(executionsSettings);

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
ExecutionsSettingsexecutionsSettings=ExecutionsSettings.newHttpJsonBuilder().build();
ExecutionsClientexecutionsClient=ExecutionsClient.create(executionsSettings);

publicstaticfinalExecutionsClientcreate()

publicstaticfinalExecutionsClientcreate(ExecutionsSettingssettings)

publicstaticfinalExecutionsClientcreate(ExecutionsStubstub)

protectedExecutionsClient(ExecutionsSettingssettings)

protectedExecutionsClient(ExecutionsStubstub)

publicbooleanawaitTermination(longduration,TimeUnitunit)

publicfinalOperationFuture<Execution,Execution>cancelExecutionAsync(CancelExecutionRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
CancelExecutionRequestrequest=
CancelExecutionRequest.newBuilder()
.setName(
ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString())
.setValidateOnly(true)
.setEtag("etag3123477")
.build();
Executionresponse=executionsClient.cancelExecutionAsync(request).get();
}

publicfinalOperationFuture<Execution,Execution>cancelExecutionAsync(ExecutionNamename)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
ExecutionNamename=ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]");
Executionresponse=executionsClient.cancelExecutionAsync(name).get();
}

publicfinalOperationFuture<Execution,Execution>cancelExecutionAsync(Stringname)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
Stringname=ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString();
Executionresponse=executionsClient.cancelExecutionAsync(name).get();
}

publicfinalUnaryCallable<CancelExecutionRequest,Operation>cancelExecutionCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
CancelExecutionRequestrequest=
CancelExecutionRequest.newBuilder()
.setName(
ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString())
.setValidateOnly(true)
.setEtag("etag3123477")
.build();
ApiFuture<Operation>future=executionsClient.cancelExecutionCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}

publicfinalOperationCallable<CancelExecutionRequest,Execution,Execution>cancelExecutionOperationCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
CancelExecutionRequestrequest=
CancelExecutionRequest.newBuilder()
.setName(
ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString())
.setValidateOnly(true)
.setEtag("etag3123477")
.build();
OperationFuture<Execution,Execution>future=
executionsClient.cancelExecutionOperationCallable().futureCall(request);
// Do something.
Executionresponse=future.get();
}

publicfinalvoidclose()

publicfinalOperationFuture<Execution,Execution>deleteExecutionAsync(DeleteExecutionRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
DeleteExecutionRequestrequest=
DeleteExecutionRequest.newBuilder()
.setName(
ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString())
.setValidateOnly(true)
.setEtag("etag3123477")
.build();
Executionresponse=executionsClient.deleteExecutionAsync(request).get();
}

publicfinalOperationFuture<Execution,Execution>deleteExecutionAsync(ExecutionNamename)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
ExecutionNamename=ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]");
Executionresponse=executionsClient.deleteExecutionAsync(name).get();
}

publicfinalOperationFuture<Execution,Execution>deleteExecutionAsync(Stringname)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
Stringname=ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString();
Executionresponse=executionsClient.deleteExecutionAsync(name).get();
}

publicfinalUnaryCallable<DeleteExecutionRequest,Operation>deleteExecutionCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
DeleteExecutionRequestrequest=
DeleteExecutionRequest.newBuilder()
.setName(
ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString())
.setValidateOnly(true)
.setEtag("etag3123477")
.build();
ApiFuture<Operation>future=executionsClient.deleteExecutionCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}

publicfinalOperationCallable<DeleteExecutionRequest,Execution,Execution>deleteExecutionOperationCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
DeleteExecutionRequestrequest=
DeleteExecutionRequest.newBuilder()
.setName(
ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString())
.setValidateOnly(true)
.setEtag("etag3123477")
.build();
OperationFuture<Execution,Execution>future=
executionsClient.deleteExecutionOperationCallable().futureCall(request);
// Do something.
Executionresponse=future.get();
}

publicfinalExecutiongetExecution(ExecutionNamename)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
ExecutionNamename=ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]");
Executionresponse=executionsClient.getExecution(name);
}

publicfinalExecutiongetExecution(GetExecutionRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
GetExecutionRequestrequest=
GetExecutionRequest.newBuilder()
.setName(
ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString())
.build();
Executionresponse=executionsClient.getExecution(request);
}

publicfinalExecutiongetExecution(Stringname)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
Stringname=ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString();
Executionresponse=executionsClient.getExecution(name);
}

publicfinalUnaryCallable<GetExecutionRequest,Execution>getExecutionCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
GetExecutionRequestrequest=
GetExecutionRequest.newBuilder()
.setName(
ExecutionName.of("[PROJECT]","[LOCATION]","[JOB]","[EXECUTION]").toString())
.build();
ApiFuture<Execution>future=executionsClient.getExecutionCallable().futureCall(request);
// Do something.
Executionresponse=future.get();
}

publicfinalOperationsClientgetHttpJsonOperationsClient()

publicfinalOperationsClientgetOperationsClient()

publicfinalExecutionsSettingsgetSettings()

publicExecutionsStubgetStub()

publicbooleanisShutdown()

publicbooleanisTerminated()

publicfinalExecutionsClient.ListExecutionsPagedResponselistExecutions(JobNameparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
JobNameparent=JobName.of("[PROJECT]","[LOCATION]","[JOB]");
for(Executionelement:executionsClient.listExecutions(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalExecutionsClient.ListExecutionsPagedResponselistExecutions(ListExecutionsRequestrequest)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
ListExecutionsRequestrequest=
ListExecutionsRequest.newBuilder()
.setParent(JobName.of("[PROJECT]","[LOCATION]","[JOB]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setShowDeleted(true)
.build();
for(Executionelement:executionsClient.listExecutions(request).iterateAll()){
// doThingsWith(element);
}
}

publicfinalExecutionsClient.ListExecutionsPagedResponselistExecutions(Stringparent)

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
Stringparent=JobName.of("[PROJECT]","[LOCATION]","[JOB]").toString();
for(Executionelement:executionsClient.listExecutions(parent).iterateAll()){
// doThingsWith(element);
}
}

publicfinalUnaryCallable<ListExecutionsRequest,ListExecutionsResponse>listExecutionsCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
ListExecutionsRequestrequest=
ListExecutionsRequest.newBuilder()
.setParent(JobName.of("[PROJECT]","[LOCATION]","[JOB]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setShowDeleted(true)
.build();
while(true){
ListExecutionsResponseresponse=executionsClient.listExecutionsCallable().call(request);
for(Executionelement:response.getExecutionsList()){
// doThingsWith(element);
}
StringnextPageToken=response.getNextPageToken();
if(!Strings.isNullOrEmpty(nextPageToken)){
request=request.toBuilder().setPageToken(nextPageToken).build();
}else{
break;
}
}
}

publicfinalUnaryCallable<ListExecutionsRequest,ExecutionsClient.ListExecutionsPagedResponse>listExecutionsPagedCallable()

// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(ExecutionsClientexecutionsClient=ExecutionsClient.create()){
ListExecutionsRequestrequest=
ListExecutionsRequest.newBuilder()
.setParent(JobName.of("[PROJECT]","[LOCATION]","[JOB]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setShowDeleted(true)
.build();
ApiFuture<Execution>future=
executionsClient.listExecutionsPagedCallable().futureCall(request);
// Do something.
for(Executionelement:future.get().iterateAll()){
// doThingsWith(element);
}
}

publicvoidshutdown()

publicvoidshutdownNow()