@Generated(value="by gapic-generator") @BetaApi public class WorkflowTemplateServiceClient extends Object implements com.google.api.gax.core.BackgroundResource
This class provides the ability to make remote calls to the backing service through method calls that map to API methods. Sample code to get started:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
WorkflowTemplate response = workflowTemplateServiceClient.createWorkflowTemplate(parent, template);
}
Note: close() needs to be called on the workflowTemplateServiceClient object to clean up resources such as threads. In the example above, try-with-resources is used, which automatically calls close().
The surface of this class includes several types of Java methods for each of the API's methods:
See the individual methods for example code.
Many parameters require resource names to be formatted in a particular way. To assist with these names, this class includes a format method for each type of name, and additionally a parse method to extract the individual identifiers contained within names that are returned.
This class can be customized by passing in a custom instance of WorkflowTemplateServiceSettings to create(). For example:
To customize credentials:
WorkflowTemplateServiceSettings workflowTemplateServiceSettings =
WorkflowTemplateServiceSettings.newBuilder()
.setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
.build();
WorkflowTemplateServiceClient workflowTemplateServiceClient =
WorkflowTemplateServiceClient.create(workflowTemplateServiceSettings);
To customize the endpoint:
WorkflowTemplateServiceSettings workflowTemplateServiceSettings =
WorkflowTemplateServiceSettings.newBuilder().setEndpoint(myEndpoint).build();
WorkflowTemplateServiceClient workflowTemplateServiceClient =
WorkflowTemplateServiceClient.create(workflowTemplateServiceSettings);
Modifier and Type | Class and Description |
---|---|
static class |
WorkflowTemplateServiceClient.ListWorkflowTemplatesFixedSizeCollection |
static class |
WorkflowTemplateServiceClient.ListWorkflowTemplatesPage |
static class |
WorkflowTemplateServiceClient.ListWorkflowTemplatesPagedResponse |
Modifier | Constructor and Description |
---|---|
protected |
WorkflowTemplateServiceClient(WorkflowTemplateServiceSettings settings)
Constructs an instance of WorkflowTemplateServiceClient, using the given settings.
|
protected |
WorkflowTemplateServiceClient(WorkflowTemplateServiceStub stub) |
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long duration,
TimeUnit unit) |
void |
close() |
static WorkflowTemplateServiceClient |
create()
Constructs an instance of WorkflowTemplateServiceClient with default settings.
|
static WorkflowTemplateServiceClient |
create(WorkflowTemplateServiceSettings settings)
Constructs an instance of WorkflowTemplateServiceClient, using the given settings.
|
static WorkflowTemplateServiceClient |
create(WorkflowTemplateServiceStub stub)
Constructs an instance of WorkflowTemplateServiceClient, using the given stub for making calls.
|
WorkflowTemplate |
createWorkflowTemplate(CreateWorkflowTemplateRequest request)
Creates new workflow template.
|
WorkflowTemplate |
createWorkflowTemplate(RegionName parent,
WorkflowTemplate template)
Creates new workflow template.
|
WorkflowTemplate |
createWorkflowTemplate(String parent,
WorkflowTemplate template)
Creates new workflow template.
|
com.google.api.gax.rpc.UnaryCallable<CreateWorkflowTemplateRequest,WorkflowTemplate> |
createWorkflowTemplateCallable()
Creates new workflow template.
|
void |
deleteWorkflowTemplate(DeleteWorkflowTemplateRequest request)
Deletes a workflow template.
|
void |
deleteWorkflowTemplate(String name)
Deletes a workflow template.
|
void |
deleteWorkflowTemplate(WorkflowTemplateName name)
Deletes a workflow template.
|
com.google.api.gax.rpc.UnaryCallable<DeleteWorkflowTemplateRequest,Empty> |
deleteWorkflowTemplateCallable()
Deletes a workflow template.
|
com.google.longrunning.OperationsClient |
getOperationsClient()
Returns the OperationsClient that can be used to query the status of a long-running operation
returned by another API method call.
|
WorkflowTemplateServiceSettings |
getSettings() |
WorkflowTemplateServiceStub |
getStub() |
WorkflowTemplate |
getWorkflowTemplate(GetWorkflowTemplateRequest request)
Retrieves the latest workflow template.
|
WorkflowTemplate |
getWorkflowTemplate(String name)
Retrieves the latest workflow template.
|
WorkflowTemplate |
getWorkflowTemplate(WorkflowTemplateName name)
Retrieves the latest workflow template.
|
com.google.api.gax.rpc.UnaryCallable<GetWorkflowTemplateRequest,WorkflowTemplate> |
getWorkflowTemplateCallable()
Retrieves the latest workflow template.
|
com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> |
instantiateInlineWorkflowTemplateAsync(InstantiateInlineWorkflowTemplateRequest request)
Instantiates a template and begins execution.
|
com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> |
instantiateInlineWorkflowTemplateAsync(RegionName parent,
WorkflowTemplate template)
Instantiates a template and begins execution.
|
com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> |
instantiateInlineWorkflowTemplateAsync(String parent,
WorkflowTemplate template)
Instantiates a template and begins execution.
|
com.google.api.gax.rpc.UnaryCallable<InstantiateInlineWorkflowTemplateRequest,com.google.longrunning.Operation> |
instantiateInlineWorkflowTemplateCallable()
Instantiates a template and begins execution.
|
com.google.api.gax.rpc.OperationCallable<InstantiateInlineWorkflowTemplateRequest,Empty,WorkflowMetadata> |
instantiateInlineWorkflowTemplateOperationCallable()
Instantiates a template and begins execution.
|
com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> |
instantiateWorkflowTemplateAsync(InstantiateWorkflowTemplateRequest request)
Instantiates a template and begins execution.
|
com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> |
instantiateWorkflowTemplateAsync(String name)
Instantiates a template and begins execution.
|
com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> |
instantiateWorkflowTemplateAsync(String name,
Map<String,String> parameters)
Instantiates a template and begins execution.
|
com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> |
instantiateWorkflowTemplateAsync(WorkflowTemplateName name)
Instantiates a template and begins execution.
|
com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> |
instantiateWorkflowTemplateAsync(WorkflowTemplateName name,
Map<String,String> parameters)
Instantiates a template and begins execution.
|
com.google.api.gax.rpc.UnaryCallable<InstantiateWorkflowTemplateRequest,com.google.longrunning.Operation> |
instantiateWorkflowTemplateCallable()
Instantiates a template and begins execution.
|
com.google.api.gax.rpc.OperationCallable<InstantiateWorkflowTemplateRequest,Empty,WorkflowMetadata> |
instantiateWorkflowTemplateOperationCallable()
Instantiates a template and begins execution.
|
boolean |
isShutdown() |
boolean |
isTerminated() |
WorkflowTemplateServiceClient.ListWorkflowTemplatesPagedResponse |
listWorkflowTemplates(ListWorkflowTemplatesRequest request)
Lists workflows that match the specified filter in the request.
|
WorkflowTemplateServiceClient.ListWorkflowTemplatesPagedResponse |
listWorkflowTemplates(RegionName parent)
Lists workflows that match the specified filter in the request.
|
WorkflowTemplateServiceClient.ListWorkflowTemplatesPagedResponse |
listWorkflowTemplates(String parent)
Lists workflows that match the specified filter in the request.
|
com.google.api.gax.rpc.UnaryCallable<ListWorkflowTemplatesRequest,ListWorkflowTemplatesResponse> |
listWorkflowTemplatesCallable()
Lists workflows that match the specified filter in the request.
|
com.google.api.gax.rpc.UnaryCallable<ListWorkflowTemplatesRequest,WorkflowTemplateServiceClient.ListWorkflowTemplatesPagedResponse> |
listWorkflowTemplatesPagedCallable()
Lists workflows that match the specified filter in the request.
|
void |
shutdown() |
void |
shutdownNow() |
WorkflowTemplate |
updateWorkflowTemplate(UpdateWorkflowTemplateRequest request)
Updates (replaces) workflow template.
|
WorkflowTemplate |
updateWorkflowTemplate(WorkflowTemplate template)
Updates (replaces) workflow template.
|
com.google.api.gax.rpc.UnaryCallable<UpdateWorkflowTemplateRequest,WorkflowTemplate> |
updateWorkflowTemplateCallable()
Updates (replaces) workflow template.
|
protected WorkflowTemplateServiceClient(WorkflowTemplateServiceSettings settings) throws IOException
IOException
@BetaApi(value="A restructuring of stub classes is planned, so this may break in the future") protected WorkflowTemplateServiceClient(WorkflowTemplateServiceStub stub)
public static final WorkflowTemplateServiceClient create() throws IOException
IOException
public static final WorkflowTemplateServiceClient create(WorkflowTemplateServiceSettings settings) throws IOException
IOException
@BetaApi(value="A restructuring of stub classes is planned, so this may break in the future") public static final WorkflowTemplateServiceClient create(WorkflowTemplateServiceStub stub)
public final WorkflowTemplateServiceSettings getSettings()
@BetaApi(value="A restructuring of stub classes is planned, so this may break in the future") public WorkflowTemplateServiceStub getStub()
@BetaApi(value="The surface for long-running operations is not stable yet and may change in the future.") public final com.google.longrunning.OperationsClient getOperationsClient()
public final WorkflowTemplate createWorkflowTemplate(RegionName parent, WorkflowTemplate template)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
WorkflowTemplate response = workflowTemplateServiceClient.createWorkflowTemplate(parent, template);
}
parent
- Required. The resource name of the region or location, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates,create`, the resource name of the region has the following format: `projects/{project_id}/regions/{region}`
* For `projects.locations.workflowTemplates.create`, the resource name of the location has the following format: `projects/{project_id}/locations/{location}`
template
- Required. The Dataproc workflow template to create.com.google.api.gax.rpc.ApiException
- if the remote call failspublic final WorkflowTemplate createWorkflowTemplate(String parent, WorkflowTemplate template)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
WorkflowTemplate response = workflowTemplateServiceClient.createWorkflowTemplate(parent.toString(), template);
}
parent
- Required. The resource name of the region or location, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates,create`, the resource name of the region has the following format: `projects/{project_id}/regions/{region}`
* For `projects.locations.workflowTemplates.create`, the resource name of the location has the following format: `projects/{project_id}/locations/{location}`
template
- Required. The Dataproc workflow template to create.com.google.api.gax.rpc.ApiException
- if the remote call failspublic final WorkflowTemplate createWorkflowTemplate(CreateWorkflowTemplateRequest request)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
CreateWorkflowTemplateRequest request = CreateWorkflowTemplateRequest.newBuilder()
.setParent(parent.toString())
.setTemplate(template)
.build();
WorkflowTemplate response = workflowTemplateServiceClient.createWorkflowTemplate(request);
}
request
- The request object containing all of the parameters for the API call.com.google.api.gax.rpc.ApiException
- if the remote call failspublic final com.google.api.gax.rpc.UnaryCallable<CreateWorkflowTemplateRequest,WorkflowTemplate> createWorkflowTemplateCallable()
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
CreateWorkflowTemplateRequest request = CreateWorkflowTemplateRequest.newBuilder()
.setParent(parent.toString())
.setTemplate(template)
.build();
ApiFuture<WorkflowTemplate> future = workflowTemplateServiceClient.createWorkflowTemplateCallable().futureCall(request);
// Do something
WorkflowTemplate response = future.get();
}
public final WorkflowTemplate getWorkflowTemplate(WorkflowTemplateName name)
Can retrieve previously instantiated template by specifying optional version parameter.
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
WorkflowTemplate response = workflowTemplateServiceClient.getWorkflowTemplate(name);
}
name
- Required. The resource name of the workflow template, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates.get`, the resource name of the template has the following format: `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
* For `projects.locations.workflowTemplates.get`, the resource name of the template has the following format: `projects/{project_id}/locations/{location}/workflowTemplates/{template_id}`
com.google.api.gax.rpc.ApiException
- if the remote call failspublic final WorkflowTemplate getWorkflowTemplate(String name)
Can retrieve previously instantiated template by specifying optional version parameter.
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
WorkflowTemplate response = workflowTemplateServiceClient.getWorkflowTemplate(name.toString());
}
name
- Required. The resource name of the workflow template, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates.get`, the resource name of the template has the following format: `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
* For `projects.locations.workflowTemplates.get`, the resource name of the template has the following format: `projects/{project_id}/locations/{location}/workflowTemplates/{template_id}`
com.google.api.gax.rpc.ApiException
- if the remote call failspublic final WorkflowTemplate getWorkflowTemplate(GetWorkflowTemplateRequest request)
Can retrieve previously instantiated template by specifying optional version parameter.
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
GetWorkflowTemplateRequest request = GetWorkflowTemplateRequest.newBuilder()
.setName(name.toString())
.build();
WorkflowTemplate response = workflowTemplateServiceClient.getWorkflowTemplate(request);
}
request
- The request object containing all of the parameters for the API call.com.google.api.gax.rpc.ApiException
- if the remote call failspublic final com.google.api.gax.rpc.UnaryCallable<GetWorkflowTemplateRequest,WorkflowTemplate> getWorkflowTemplateCallable()
Can retrieve previously instantiated template by specifying optional version parameter.
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
GetWorkflowTemplateRequest request = GetWorkflowTemplateRequest.newBuilder()
.setName(name.toString())
.build();
ApiFuture<WorkflowTemplate> future = workflowTemplateServiceClient.getWorkflowTemplateCallable().futureCall(request);
// Do something
WorkflowTemplate response = future.get();
}
@BetaApi(value="The surface for long-running operations is not stable yet and may change in the future.") public final com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> instantiateWorkflowTemplateAsync(WorkflowTemplateName name)
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
workflowTemplateServiceClient.instantiateWorkflowTemplateAsync(name).get();
}
name
- Required. The resource name of the workflow template, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates.instantiate`, the resource name of the template has the following format: `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
* For `projects.locations.workflowTemplates.instantiate`, the resource name of the template has the following format: `projects/{project_id}/locations/{location}/workflowTemplates/{template_id}`
com.google.api.gax.rpc.ApiException
- if the remote call fails@BetaApi(value="The surface for long-running operations is not stable yet and may change in the future.") public final com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> instantiateWorkflowTemplateAsync(String name)
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
workflowTemplateServiceClient.instantiateWorkflowTemplateAsync(name.toString()).get();
}
name
- Required. The resource name of the workflow template, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates.instantiate`, the resource name of the template has the following format: `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
* For `projects.locations.workflowTemplates.instantiate`, the resource name of the template has the following format: `projects/{project_id}/locations/{location}/workflowTemplates/{template_id}`
com.google.api.gax.rpc.ApiException
- if the remote call fails@BetaApi(value="The surface for long-running operations is not stable yet and may change in the future.") public final com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> instantiateWorkflowTemplateAsync(WorkflowTemplateName name, Map<String,String> parameters)
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
Map<String, String> parameters = new HashMap<>();
workflowTemplateServiceClient.instantiateWorkflowTemplateAsync(name, parameters).get();
}
name
- Required. The resource name of the workflow template, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates.instantiate`, the resource name of the template has the following format: `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
* For `projects.locations.workflowTemplates.instantiate`, the resource name of the template has the following format: `projects/{project_id}/locations/{location}/workflowTemplates/{template_id}`
parameters
- Optional. Map from parameter names to values that should be used for those
parameters. Values may not exceed 100 characters.com.google.api.gax.rpc.ApiException
- if the remote call fails@BetaApi(value="The surface for long-running operations is not stable yet and may change in the future.") public final com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> instantiateWorkflowTemplateAsync(String name, Map<String,String> parameters)
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
Map<String, String> parameters = new HashMap<>();
workflowTemplateServiceClient.instantiateWorkflowTemplateAsync(name.toString(), parameters).get();
}
name
- Required. The resource name of the workflow template, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates.instantiate`, the resource name of the template has the following format: `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
* For `projects.locations.workflowTemplates.instantiate`, the resource name of the template has the following format: `projects/{project_id}/locations/{location}/workflowTemplates/{template_id}`
parameters
- Optional. Map from parameter names to values that should be used for those
parameters. Values may not exceed 100 characters.com.google.api.gax.rpc.ApiException
- if the remote call fails@BetaApi(value="The surface for long-running operations is not stable yet and may change in the future.") public final com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> instantiateWorkflowTemplateAsync(InstantiateWorkflowTemplateRequest request)
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
InstantiateWorkflowTemplateRequest request = InstantiateWorkflowTemplateRequest.newBuilder()
.setName(name.toString())
.build();
workflowTemplateServiceClient.instantiateWorkflowTemplateAsync(request).get();
}
request
- The request object containing all of the parameters for the API call.com.google.api.gax.rpc.ApiException
- if the remote call fails@BetaApi(value="The surface for use by generated code is not stable yet and may change in the future.") public final com.google.api.gax.rpc.OperationCallable<InstantiateWorkflowTemplateRequest,Empty,WorkflowMetadata> instantiateWorkflowTemplateOperationCallable()
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
InstantiateWorkflowTemplateRequest request = InstantiateWorkflowTemplateRequest.newBuilder()
.setName(name.toString())
.build();
OperationFuture<Empty, WorkflowMetadata> future = workflowTemplateServiceClient.instantiateWorkflowTemplateOperationCallable().futureCall(request);
// Do something
future.get();
}
public final com.google.api.gax.rpc.UnaryCallable<InstantiateWorkflowTemplateRequest,com.google.longrunning.Operation> instantiateWorkflowTemplateCallable()
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
InstantiateWorkflowTemplateRequest request = InstantiateWorkflowTemplateRequest.newBuilder()
.setName(name.toString())
.build();
ApiFuture<Operation> future = workflowTemplateServiceClient.instantiateWorkflowTemplateCallable().futureCall(request);
// Do something
future.get();
}
@BetaApi(value="The surface for long-running operations is not stable yet and may change in the future.") public final com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> instantiateInlineWorkflowTemplateAsync(RegionName parent, WorkflowTemplate template)
This method is equivalent to executing the sequence [CreateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.CreateWorkflowTemplate], [InstantiateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.InstantiateWorkflowTemplate], [DeleteWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.DeleteWorkflowTemplate].
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
workflowTemplateServiceClient.instantiateInlineWorkflowTemplateAsync(parent, template).get();
}
parent
- Required. The resource name of the region or location, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates,instantiateinline`, the resource name of the region has the following format: `projects/{project_id}/regions/{region}`
* For `projects.locations.workflowTemplates.instantiateinline`, the resource name of the location has the following format: `projects/{project_id}/locations/{location}`
template
- Required. The workflow template to instantiate.com.google.api.gax.rpc.ApiException
- if the remote call fails@BetaApi(value="The surface for long-running operations is not stable yet and may change in the future.") public final com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> instantiateInlineWorkflowTemplateAsync(String parent, WorkflowTemplate template)
This method is equivalent to executing the sequence [CreateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.CreateWorkflowTemplate], [InstantiateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.InstantiateWorkflowTemplate], [DeleteWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.DeleteWorkflowTemplate].
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
workflowTemplateServiceClient.instantiateInlineWorkflowTemplateAsync(parent.toString(), template).get();
}
parent
- Required. The resource name of the region or location, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates,instantiateinline`, the resource name of the region has the following format: `projects/{project_id}/regions/{region}`
* For `projects.locations.workflowTemplates.instantiateinline`, the resource name of the location has the following format: `projects/{project_id}/locations/{location}`
template
- Required. The workflow template to instantiate.com.google.api.gax.rpc.ApiException
- if the remote call fails@BetaApi(value="The surface for long-running operations is not stable yet and may change in the future.") public final com.google.api.gax.longrunning.OperationFuture<Empty,WorkflowMetadata> instantiateInlineWorkflowTemplateAsync(InstantiateInlineWorkflowTemplateRequest request)
This method is equivalent to executing the sequence [CreateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.CreateWorkflowTemplate], [InstantiateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.InstantiateWorkflowTemplate], [DeleteWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.DeleteWorkflowTemplate].
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
InstantiateInlineWorkflowTemplateRequest request = InstantiateInlineWorkflowTemplateRequest.newBuilder()
.setParent(parent.toString())
.setTemplate(template)
.build();
workflowTemplateServiceClient.instantiateInlineWorkflowTemplateAsync(request).get();
}
request
- The request object containing all of the parameters for the API call.com.google.api.gax.rpc.ApiException
- if the remote call fails@BetaApi(value="The surface for use by generated code is not stable yet and may change in the future.") public final com.google.api.gax.rpc.OperationCallable<InstantiateInlineWorkflowTemplateRequest,Empty,WorkflowMetadata> instantiateInlineWorkflowTemplateOperationCallable()
This method is equivalent to executing the sequence [CreateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.CreateWorkflowTemplate], [InstantiateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.InstantiateWorkflowTemplate], [DeleteWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.DeleteWorkflowTemplate].
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
InstantiateInlineWorkflowTemplateRequest request = InstantiateInlineWorkflowTemplateRequest.newBuilder()
.setParent(parent.toString())
.setTemplate(template)
.build();
OperationFuture<Empty, WorkflowMetadata> future = workflowTemplateServiceClient.instantiateInlineWorkflowTemplateOperationCallable().futureCall(request);
// Do something
future.get();
}
public final com.google.api.gax.rpc.UnaryCallable<InstantiateInlineWorkflowTemplateRequest,com.google.longrunning.Operation> instantiateInlineWorkflowTemplateCallable()
This method is equivalent to executing the sequence [CreateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.CreateWorkflowTemplate], [InstantiateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.InstantiateWorkflowTemplate], [DeleteWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.DeleteWorkflowTemplate].
The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.
The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.
The [Operation.metadata][google.longrunning.Operation.metadata] will be [WorkflowMetadata](/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).
On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
InstantiateInlineWorkflowTemplateRequest request = InstantiateInlineWorkflowTemplateRequest.newBuilder()
.setParent(parent.toString())
.setTemplate(template)
.build();
ApiFuture<Operation> future = workflowTemplateServiceClient.instantiateInlineWorkflowTemplateCallable().futureCall(request);
// Do something
future.get();
}
public final WorkflowTemplate updateWorkflowTemplate(WorkflowTemplate template)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
WorkflowTemplate response = workflowTemplateServiceClient.updateWorkflowTemplate(template);
}
template
- Required. The updated workflow template.
The `template.version` field must match the current version.
com.google.api.gax.rpc.ApiException
- if the remote call failspublic final WorkflowTemplate updateWorkflowTemplate(UpdateWorkflowTemplateRequest request)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
UpdateWorkflowTemplateRequest request = UpdateWorkflowTemplateRequest.newBuilder()
.setTemplate(template)
.build();
WorkflowTemplate response = workflowTemplateServiceClient.updateWorkflowTemplate(request);
}
request
- The request object containing all of the parameters for the API call.com.google.api.gax.rpc.ApiException
- if the remote call failspublic final com.google.api.gax.rpc.UnaryCallable<UpdateWorkflowTemplateRequest,WorkflowTemplate> updateWorkflowTemplateCallable()
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplate template = WorkflowTemplate.newBuilder().build();
UpdateWorkflowTemplateRequest request = UpdateWorkflowTemplateRequest.newBuilder()
.setTemplate(template)
.build();
ApiFuture<WorkflowTemplate> future = workflowTemplateServiceClient.updateWorkflowTemplateCallable().futureCall(request);
// Do something
WorkflowTemplate response = future.get();
}
public final WorkflowTemplateServiceClient.ListWorkflowTemplatesPagedResponse listWorkflowTemplates(RegionName parent)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
for (WorkflowTemplate element : workflowTemplateServiceClient.listWorkflowTemplates(parent).iterateAll()) {
// doThingsWith(element);
}
}
parent
- Required. The resource name of the region or location, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates,list`, the resource name of the region has the following format: `projects/{project_id}/regions/{region}`
* For `projects.locations.workflowTemplates.list`, the resource name of the location has the following format: `projects/{project_id}/locations/{location}`
com.google.api.gax.rpc.ApiException
- if the remote call failspublic final WorkflowTemplateServiceClient.ListWorkflowTemplatesPagedResponse listWorkflowTemplates(String parent)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
for (WorkflowTemplate element : workflowTemplateServiceClient.listWorkflowTemplates(parent.toString()).iterateAll()) {
// doThingsWith(element);
}
}
parent
- Required. The resource name of the region or location, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates,list`, the resource name of the region has the following format: `projects/{project_id}/regions/{region}`
* For `projects.locations.workflowTemplates.list`, the resource name of the location has the following format: `projects/{project_id}/locations/{location}`
com.google.api.gax.rpc.ApiException
- if the remote call failspublic final WorkflowTemplateServiceClient.ListWorkflowTemplatesPagedResponse listWorkflowTemplates(ListWorkflowTemplatesRequest request)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
ListWorkflowTemplatesRequest request = ListWorkflowTemplatesRequest.newBuilder()
.setParent(parent.toString())
.build();
for (WorkflowTemplate element : workflowTemplateServiceClient.listWorkflowTemplates(request).iterateAll()) {
// doThingsWith(element);
}
}
request
- The request object containing all of the parameters for the API call.com.google.api.gax.rpc.ApiException
- if the remote call failspublic final com.google.api.gax.rpc.UnaryCallable<ListWorkflowTemplatesRequest,WorkflowTemplateServiceClient.ListWorkflowTemplatesPagedResponse> listWorkflowTemplatesPagedCallable()
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
ListWorkflowTemplatesRequest request = ListWorkflowTemplatesRequest.newBuilder()
.setParent(parent.toString())
.build();
ApiFuture<ListWorkflowTemplatesPagedResponse> future = workflowTemplateServiceClient.listWorkflowTemplatesPagedCallable().futureCall(request);
// Do something
for (WorkflowTemplate element : future.get().iterateAll()) {
// doThingsWith(element);
}
}
public final com.google.api.gax.rpc.UnaryCallable<ListWorkflowTemplatesRequest,ListWorkflowTemplatesResponse> listWorkflowTemplatesCallable()
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
RegionName parent = RegionName.of("[PROJECT]", "[REGION]");
ListWorkflowTemplatesRequest request = ListWorkflowTemplatesRequest.newBuilder()
.setParent(parent.toString())
.build();
while (true) {
ListWorkflowTemplatesResponse response = workflowTemplateServiceClient.listWorkflowTemplatesCallable().call(request);
for (WorkflowTemplate element : response.getTemplatesList()) {
// doThingsWith(element);
}
String nextPageToken = response.getNextPageToken();
if (!Strings.isNullOrEmpty(nextPageToken)) {
request = request.toBuilder().setPageToken(nextPageToken).build();
} else {
break;
}
}
}
public final void deleteWorkflowTemplate(WorkflowTemplateName name)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
workflowTemplateServiceClient.deleteWorkflowTemplate(name);
}
name
- Required. The resource name of the workflow template, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates.delete`, the resource name of the template has the following format: `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
* For `projects.locations.workflowTemplates.instantiate`, the resource name of the template has the following format: `projects/{project_id}/locations/{location}/workflowTemplates/{template_id}`
com.google.api.gax.rpc.ApiException
- if the remote call failspublic final void deleteWorkflowTemplate(String name)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
workflowTemplateServiceClient.deleteWorkflowTemplate(name.toString());
}
name
- Required. The resource name of the workflow template, as described in
https://cloud.google.com/apis/design/resource_names.
* For `projects.regions.workflowTemplates.delete`, the resource name of the template has the following format: `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
* For `projects.locations.workflowTemplates.instantiate`, the resource name of the template has the following format: `projects/{project_id}/locations/{location}/workflowTemplates/{template_id}`
com.google.api.gax.rpc.ApiException
- if the remote call failspublic final void deleteWorkflowTemplate(DeleteWorkflowTemplateRequest request)
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
DeleteWorkflowTemplateRequest request = DeleteWorkflowTemplateRequest.newBuilder()
.setName(name.toString())
.build();
workflowTemplateServiceClient.deleteWorkflowTemplate(request);
}
request
- The request object containing all of the parameters for the API call.com.google.api.gax.rpc.ApiException
- if the remote call failspublic final com.google.api.gax.rpc.UnaryCallable<DeleteWorkflowTemplateRequest,Empty> deleteWorkflowTemplateCallable()
Sample code:
try (WorkflowTemplateServiceClient workflowTemplateServiceClient = WorkflowTemplateServiceClient.create()) {
WorkflowTemplateName name = WorkflowTemplateName.of("[PROJECT]", "[REGION]", "[WORKFLOW_TEMPLATE]");
DeleteWorkflowTemplateRequest request = DeleteWorkflowTemplateRequest.newBuilder()
.setName(name.toString())
.build();
ApiFuture<Void> future = workflowTemplateServiceClient.deleteWorkflowTemplateCallable().futureCall(request);
// Do something
future.get();
}
public final void close()
close
in interface AutoCloseable
public void shutdown()
shutdown
in interface com.google.api.gax.core.BackgroundResource
public boolean isShutdown()
isShutdown
in interface com.google.api.gax.core.BackgroundResource
public boolean isTerminated()
isTerminated
in interface com.google.api.gax.core.BackgroundResource
public void shutdownNow()
shutdownNow
in interface com.google.api.gax.core.BackgroundResource
public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException
awaitTermination
in interface com.google.api.gax.core.BackgroundResource
InterruptedException
Copyright © 2019 Google LLC. All rights reserved.