Class WorkflowTemplateServiceGrpc.WorkflowTemplateServiceImplBase (4.3.0)

Version 4.3.0

• 4.50.0 (latest)
• 4.49.0
• 4.48.0
• 4.46.0
• 4.45.0
• 4.44.0
• 4.43.0
• 4.42.0
• 4.41.0
• 4.40.0
• 4.39.0
• 4.38.0
• 4.37.0
• 4.36.0
• 4.34.0
• 4.33.0
• 4.32.0
• 4.31.0
• 4.30.0
• 4.29.0
• 4.28.0
• 4.27.0
• 4.26.0
• 4.25.0
• 4.24.0
• 4.21.0
• 4.20.0
• 4.19.0
• 4.18.0
• 4.17.0
• 4.16.0
• 4.15.0
• 4.14.0
• 4.13.0
• 4.12.0
• 4.11.0
• 4.10.0
• 4.9.0
• 4.8.0
• 4.6.0
• 4.5.0
• 4.4.0
• 4.3.0
• 4.2.0
• 4.1.0
• 4.0.8
• 3.1.2
• 3.0.3
• 2.3.1

public abstract static class WorkflowTemplateServiceGrpc.WorkflowTemplateServiceImplBase implements BindableService

The API interface for managing Workflow Templates in the Dataproc API.

Inheritance

java.lang.Object > WorkflowTemplateServiceGrpc.WorkflowTemplateServiceImplBase

Implements

io.grpc.BindableService

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

WorkflowTemplateServiceImplBase()

public WorkflowTemplateServiceImplBase()

Methods

bindService()

public final ServerServiceDefinition bindService()

Returns

Type	Description
io.grpc.ServerServiceDefinition

createWorkflowTemplate(CreateWorkflowTemplateRequest request, StreamObserver<WorkflowTemplate> responseObserver)

public void createWorkflowTemplate(CreateWorkflowTemplateRequest request, StreamObserver<WorkflowTemplate> responseObserver)

Creates new workflow template.

Parameters

Name	Description
request	CreateWorkflowTemplateRequest
responseObserver	io.grpc.stub.StreamObserver<WorkflowTemplate>

deleteWorkflowTemplate(DeleteWorkflowTemplateRequest request, StreamObserver<Empty> responseObserver)

public void deleteWorkflowTemplate(DeleteWorkflowTemplateRequest request, StreamObserver<Empty> responseObserver)

Deletes a workflow template. It does not cancel in-progress workflows.

Parameters

Name	Description
request	DeleteWorkflowTemplateRequest
responseObserver	io.grpc.stub.StreamObserver<Empty>

getWorkflowTemplate(GetWorkflowTemplateRequest request, StreamObserver<WorkflowTemplate> responseObserver)

public void getWorkflowTemplate(GetWorkflowTemplateRequest request, StreamObserver<WorkflowTemplate> responseObserver)

Retrieves the latest workflow template. Can retrieve previously instantiated template by specifying optional version parameter.

Parameters

Name	Description
request	GetWorkflowTemplateRequest
responseObserver	io.grpc.stub.StreamObserver<WorkflowTemplate>

instantiateInlineWorkflowTemplate(InstantiateInlineWorkflowTemplateRequest request, StreamObserver<Operation> responseObserver)

public void instantiateInlineWorkflowTemplate(InstantiateInlineWorkflowTemplateRequest request, StreamObserver<Operation> responseObserver)

Instantiates a template and begins execution. This method is equivalent to executing the sequence CreateWorkflowTemplate, InstantiateWorkflowTemplate, DeleteWorkflowTemplate. The returned Operation can be used to track execution of workflow by polling operations.get. The Operation will complete when entire workflow is finished. The running workflow can be aborted via operations.cancel. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted. The Operation.metadata will be WorkflowMetadata. Also see Using WorkflowMetadata. On successful completion, Operation.response will be Empty.

Parameters

Name	Description
request	InstantiateInlineWorkflowTemplateRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

instantiateWorkflowTemplate(InstantiateWorkflowTemplateRequest request, StreamObserver<Operation> responseObserver)

public void instantiateWorkflowTemplate(InstantiateWorkflowTemplateRequest request, StreamObserver<Operation> responseObserver)

Instantiates a template and begins execution. The returned Operation can be used to track execution of workflow by polling operations.get. The Operation will complete when entire workflow is finished. The running workflow can be aborted via operations.cancel. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted. The Operation.metadata will be WorkflowMetadata. Also see Using WorkflowMetadata. On successful completion, Operation.response will be Empty.

Parameters

Name	Description
request	InstantiateWorkflowTemplateRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

listWorkflowTemplates(ListWorkflowTemplatesRequest request, StreamObserver<ListWorkflowTemplatesResponse> responseObserver)

public void listWorkflowTemplates(ListWorkflowTemplatesRequest request, StreamObserver<ListWorkflowTemplatesResponse> responseObserver)

Lists workflows that match the specified filter in the request.

Parameters

Name	Description
request	ListWorkflowTemplatesRequest
responseObserver	io.grpc.stub.StreamObserver<ListWorkflowTemplatesResponse>

updateWorkflowTemplate(UpdateWorkflowTemplateRequest request, StreamObserver<WorkflowTemplate> responseObserver)

public void updateWorkflowTemplate(UpdateWorkflowTemplateRequest request, StreamObserver<WorkflowTemplate> responseObserver)

Updates (replaces) workflow template. The updated template must contain version that matches the current server version.

Parameters

Name	Description
request	UpdateWorkflowTemplateRequest
responseObserver	io.grpc.stub.StreamObserver<WorkflowTemplate>