Package com.google.cloud.dataproc.v1
Class WorkflowTemplateServiceGrpc.WorkflowTemplateServiceBlockingStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<S>
-
- io.grpc.stub.AbstractBlockingStub<WorkflowTemplateServiceGrpc.WorkflowTemplateServiceBlockingStub>
-
- com.google.cloud.dataproc.v1.WorkflowTemplateServiceGrpc.WorkflowTemplateServiceBlockingStub
-
- Enclosing class:
- WorkflowTemplateServiceGrpc
public static final class WorkflowTemplateServiceGrpc.WorkflowTemplateServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub<WorkflowTemplateServiceGrpc.WorkflowTemplateServiceBlockingStub>
A stub to allow clients to do synchronous rpc calls to service WorkflowTemplateService.The API interface for managing Workflow Templates in the Dataproc API.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected WorkflowTemplateServiceGrpc.WorkflowTemplateServiceBlockingStub
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
WorkflowTemplate
createWorkflowTemplate(CreateWorkflowTemplateRequest request)
Creates new workflow template.com.google.protobuf.Empty
deleteWorkflowTemplate(DeleteWorkflowTemplateRequest request)
Deletes a workflow template.WorkflowTemplate
getWorkflowTemplate(GetWorkflowTemplateRequest request)
Retrieves the latest workflow template.com.google.longrunning.Operation
instantiateInlineWorkflowTemplate(InstantiateInlineWorkflowTemplateRequest request)
Instantiates a template and begins execution.com.google.longrunning.Operation
instantiateWorkflowTemplate(InstantiateWorkflowTemplateRequest request)
Instantiates a template and begins execution.ListWorkflowTemplatesResponse
listWorkflowTemplates(ListWorkflowTemplatesRequest request)
Lists workflows that match the specified filter in the request.WorkflowTemplate
updateWorkflowTemplate(UpdateWorkflowTemplateRequest request)
Updates (replaces) workflow template.
-
-
-
Method Detail
-
build
protected WorkflowTemplateServiceGrpc.WorkflowTemplateServiceBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
build
in classio.grpc.stub.AbstractStub<WorkflowTemplateServiceGrpc.WorkflowTemplateServiceBlockingStub>
-
createWorkflowTemplate
public WorkflowTemplate createWorkflowTemplate(CreateWorkflowTemplateRequest request)
Creates new workflow template.
-
getWorkflowTemplate
public WorkflowTemplate getWorkflowTemplate(GetWorkflowTemplateRequest request)
Retrieves the latest workflow template. Can retrieve previously instantiated template by specifying optional version parameter.
-
instantiateWorkflowTemplate
public com.google.longrunning.Operation instantiateWorkflowTemplate(InstantiateWorkflowTemplateRequest request)
Instantiates a template and begins execution. 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](https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](https://cloud.google.com/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata). On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
-
instantiateInlineWorkflowTemplate
public com.google.longrunning.Operation instantiateInlineWorkflowTemplate(InstantiateInlineWorkflowTemplateRequest request)
Instantiates a template and begins execution. 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](https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see [Using WorkflowMetadata](https://cloud.google.com/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata). On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].
-
updateWorkflowTemplate
public WorkflowTemplate updateWorkflowTemplate(UpdateWorkflowTemplateRequest request)
Updates (replaces) workflow template. The updated template must contain version that matches the current server version.
-
listWorkflowTemplates
public ListWorkflowTemplatesResponse listWorkflowTemplates(ListWorkflowTemplatesRequest request)
Lists workflows that match the specified filter in the request.
-
deleteWorkflowTemplate
public com.google.protobuf.Empty deleteWorkflowTemplate(DeleteWorkflowTemplateRequest request)
Deletes a workflow template. It does not cancel in-progress workflows.
-
-