com.google.cloud.dataproc.v1

Class WorkflowTemplateServiceGrpc.WorkflowTemplateServiceImplBase

java.lang.Object

com.google.cloud.dataproc.v1.WorkflowTemplateServiceGrpc.WorkflowTemplateServiceImplBase

All Implemented Interfaces:

BindableService

Enclosing class:

WorkflowTemplateServiceGrpc

public abstract static class WorkflowTemplateServiceGrpc.WorkflowTemplateServiceImplBase
extends Object
implements BindableService

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

Constructor Summary

Constructors

Constructor and Description
WorkflowTemplateServiceImplBase()

Method Summary

Modifier and Type	Method and Description
ServerServiceDefinition	bindService()
void	createWorkflowTemplate(CreateWorkflowTemplateRequest request, StreamObserver<WorkflowTemplate> responseObserver) Creates new workflow template.
void	deleteWorkflowTemplate(DeleteWorkflowTemplateRequest request, StreamObserver<Empty> responseObserver) Deletes a workflow template.
void	getWorkflowTemplate(GetWorkflowTemplateRequest request, StreamObserver<WorkflowTemplate> responseObserver) Retrieves the latest workflow template.
void	instantiateInlineWorkflowTemplate(InstantiateInlineWorkflowTemplateRequest request, StreamObserver<Operation> responseObserver) Instantiates a template and begins execution.
void	instantiateWorkflowTemplate(InstantiateWorkflowTemplateRequest request, StreamObserver<Operation> responseObserver) Instantiates a template and begins execution.
void	listWorkflowTemplates(ListWorkflowTemplatesRequest request, StreamObserver<ListWorkflowTemplatesResponse> responseObserver) Lists workflows that match the specified filter in the request.
void	updateWorkflowTemplate(UpdateWorkflowTemplateRequest request, StreamObserver<WorkflowTemplate> responseObserver) Updates (replaces) workflow template.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkflowTemplateServiceImplBase

public WorkflowTemplateServiceImplBase()

Method Detail

createWorkflowTemplate

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

 Creates new workflow template.
 

getWorkflowTemplate

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

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

instantiateWorkflowTemplate

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][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 void instantiateInlineWorkflowTemplate(InstantiateInlineWorkflowTemplateRequest request,
                                              StreamObserver<Operation> responseObserver)

 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 void updateWorkflowTemplate(UpdateWorkflowTemplateRequest request,
                                   StreamObserver<WorkflowTemplate> responseObserver)

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

listWorkflowTemplates

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

 Lists workflows that match the specified filter in the request.
 

deleteWorkflowTemplate

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

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

bindService

public final ServerServiceDefinition bindService()

Specified by:

bindService in interface BindableService