com.google.cloud.dataproc.v1

Class JobControllerGrpc.JobControllerImplBase

java.lang.Object

com.google.cloud.dataproc.v1.JobControllerGrpc.JobControllerImplBase

All Implemented Interfaces:

io.grpc.BindableService

Enclosing class:

JobControllerGrpc

public abstract static class JobControllerGrpc.JobControllerImplBase
extends java.lang.Object
implements io.grpc.BindableService

 The JobController provides methods to manage jobs.
 

Constructor Summary

Constructors

Constructor and Description
JobControllerImplBase()

Method Summary

Modifier and Type	Method and Description
io.grpc.ServerServiceDefinition	bindService()
void	cancelJob(CancelJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver) Starts a job cancellation request.
void	deleteJob(DeleteJobRequest request, io.grpc.stub.StreamObserver<Empty> responseObserver) Deletes the job from the project.
void	getJob(GetJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver) Gets the resource representation for a job in a project.
void	listJobs(ListJobsRequest request, io.grpc.stub.StreamObserver<ListJobsResponse> responseObserver) Lists regions/{region}/jobs in a project.
void	submitJob(SubmitJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver) Submits a job to a cluster.
void	updateJob(UpdateJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver) Updates a job in a project.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobControllerImplBase

public JobControllerImplBase()

Method Detail

submitJob

public void submitJob(SubmitJobRequest request,
                      io.grpc.stub.StreamObserver<Job> responseObserver)

 Submits a job to a cluster.
 

getJob

public void getJob(GetJobRequest request,
                   io.grpc.stub.StreamObserver<Job> responseObserver)

 Gets the resource representation for a job in a project.
 

listJobs

public void listJobs(ListJobsRequest request,
                     io.grpc.stub.StreamObserver<ListJobsResponse> responseObserver)

 Lists regions/{region}/jobs in a project.
 

updateJob

public void updateJob(UpdateJobRequest request,
                      io.grpc.stub.StreamObserver<Job> responseObserver)

 Updates a job in a project.
 

cancelJob

public void cancelJob(CancelJobRequest request,
                      io.grpc.stub.StreamObserver<Job> responseObserver)

 Starts a job cancellation request. To access the job resource
 after cancellation, call
 [regions/{region}/jobs.list](/dataproc/docs/reference/rest/v1/projects.regions.jobs/list) or
 [regions/{region}/jobs.get](/dataproc/docs/reference/rest/v1/projects.regions.jobs/get).
 

deleteJob

public void deleteJob(DeleteJobRequest request,
                      io.grpc.stub.StreamObserver<Empty> responseObserver)

 Deletes the job from the project. If the job is active, the delete fails,
 and the response returns `FAILED_PRECONDITION`.
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService