Package com.google.cloud.dataproc.v1

Class WorkflowTemplateServiceGrpc.WorkflowTemplateServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<WorkflowTemplateServiceGrpc.WorkflowTemplateServiceStub>

com.google.cloud.dataproc.v1.WorkflowTemplateServiceGrpc.WorkflowTemplateServiceStub

Enclosing class:

WorkflowTemplateServiceGrpc

public static final class WorkflowTemplateServiceGrpc.WorkflowTemplateServiceStub
extends io.grpc.stub.AbstractAsyncStub<WorkflowTemplateServiceGrpc.WorkflowTemplateServiceStub>

A stub to allow clients to do asynchronous rpc calls to service WorkflowTemplateService.

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

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected WorkflowTemplateServiceGrpc.WorkflowTemplateServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	createWorkflowTemplate(CreateWorkflowTemplateRequest request, io.grpc.stub.StreamObserver<WorkflowTemplate> responseObserver)	Creates new workflow template.
void	deleteWorkflowTemplate(DeleteWorkflowTemplateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Deletes a workflow template.
void	getWorkflowTemplate(GetWorkflowTemplateRequest request, io.grpc.stub.StreamObserver<WorkflowTemplate> responseObserver)	Retrieves the latest workflow template.
void	instantiateInlineWorkflowTemplate(InstantiateInlineWorkflowTemplateRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Instantiates a template and begins execution.
void	instantiateWorkflowTemplate(InstantiateWorkflowTemplateRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)	Instantiates a template and begins execution.
void	listWorkflowTemplates(ListWorkflowTemplatesRequest request, io.grpc.stub.StreamObserver<ListWorkflowTemplatesResponse> responseObserver)	Lists workflows that match the specified filter in the request.
void	updateWorkflowTemplate(UpdateWorkflowTemplateRequest request, io.grpc.stub.StreamObserver<WorkflowTemplate> responseObserver)	Updates (replaces) workflow template.

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected WorkflowTemplateServiceGrpc.WorkflowTemplateServiceStub build(io.grpc.Channel channel,
                                                                        io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<WorkflowTemplateServiceGrpc.WorkflowTemplateServiceStub>

createWorkflowTemplate

public void createWorkflowTemplate(CreateWorkflowTemplateRequest request,
                                   io.grpc.stub.StreamObserver<WorkflowTemplate> responseObserver)

 Creates new workflow template.
 

getWorkflowTemplate

public void getWorkflowTemplate(GetWorkflowTemplateRequest request,
                                io.grpc.stub.StreamObserver<WorkflowTemplate> responseObserver)

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

instantiateWorkflowTemplate

public void instantiateWorkflowTemplate(InstantiateWorkflowTemplateRequest request,
                                        io.grpc.stub.StreamObserver<com.google.longrunning.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,
                                              io.grpc.stub.StreamObserver<com.google.longrunning.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,
                                   io.grpc.stub.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,
                                  io.grpc.stub.StreamObserver<ListWorkflowTemplatesResponse> responseObserver)

 Lists workflows that match the specified filter in the request.
 

deleteWorkflowTemplate

public void deleteWorkflowTemplate(DeleteWorkflowTemplateRequest request,
                                   io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

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