@Generated(value="by gapic-generator") @BetaApi(value="A restructuring of stub classes is planned, so this may break in the future") public class GrpcJobControllerStub extends JobControllerStub
This class is for advanced usage and reflects the underlying API directly.
Modifier | Constructor and Description |
---|---|
protected |
GrpcJobControllerStub(JobControllerStubSettings settings,
ClientContext clientContext)
Constructs an instance of GrpcJobControllerStub, using the given settings.
|
protected |
GrpcJobControllerStub(JobControllerStubSettings settings,
ClientContext clientContext,
GrpcStubCallableFactory callableFactory)
Constructs an instance of GrpcJobControllerStub, using the given settings.
|
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long duration,
TimeUnit unit) |
UnaryCallable<com.google.cloud.dataproc.v1beta2.CancelJobRequest,com.google.cloud.dataproc.v1beta2.Job> |
cancelJobCallable() |
void |
close() |
static GrpcJobControllerStub |
create(ClientContext clientContext) |
static GrpcJobControllerStub |
create(ClientContext clientContext,
GrpcStubCallableFactory callableFactory) |
static GrpcJobControllerStub |
create(JobControllerStubSettings settings) |
UnaryCallable<com.google.cloud.dataproc.v1beta2.DeleteJobRequest,Empty> |
deleteJobCallable() |
UnaryCallable<com.google.cloud.dataproc.v1beta2.GetJobRequest,com.google.cloud.dataproc.v1beta2.Job> |
getJobCallable() |
boolean |
isShutdown() |
boolean |
isTerminated() |
UnaryCallable<com.google.cloud.dataproc.v1beta2.ListJobsRequest,com.google.cloud.dataproc.v1beta2.ListJobsResponse> |
listJobsCallable() |
UnaryCallable<com.google.cloud.dataproc.v1beta2.ListJobsRequest,JobControllerClient.ListJobsPagedResponse> |
listJobsPagedCallable() |
void |
shutdown() |
void |
shutdownNow() |
UnaryCallable<com.google.cloud.dataproc.v1beta2.SubmitJobRequest,com.google.cloud.dataproc.v1beta2.Job> |
submitJobCallable() |
UnaryCallable<com.google.cloud.dataproc.v1beta2.UpdateJobRequest,com.google.cloud.dataproc.v1beta2.Job> |
updateJobCallable() |
protected GrpcJobControllerStub(JobControllerStubSettings settings, ClientContext clientContext) throws IOException
IOException
protected GrpcJobControllerStub(JobControllerStubSettings settings, ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException
IOException
public static final GrpcJobControllerStub create(JobControllerStubSettings settings) throws IOException
IOException
public static final GrpcJobControllerStub create(ClientContext clientContext) throws IOException
IOException
public static final GrpcJobControllerStub create(ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException
IOException
public UnaryCallable<com.google.cloud.dataproc.v1beta2.SubmitJobRequest,com.google.cloud.dataproc.v1beta2.Job> submitJobCallable()
submitJobCallable
in class JobControllerStub
public UnaryCallable<com.google.cloud.dataproc.v1beta2.GetJobRequest,com.google.cloud.dataproc.v1beta2.Job> getJobCallable()
getJobCallable
in class JobControllerStub
public UnaryCallable<com.google.cloud.dataproc.v1beta2.ListJobsRequest,JobControllerClient.ListJobsPagedResponse> listJobsPagedCallable()
listJobsPagedCallable
in class JobControllerStub
public UnaryCallable<com.google.cloud.dataproc.v1beta2.ListJobsRequest,com.google.cloud.dataproc.v1beta2.ListJobsResponse> listJobsCallable()
listJobsCallable
in class JobControllerStub
public UnaryCallable<com.google.cloud.dataproc.v1beta2.UpdateJobRequest,com.google.cloud.dataproc.v1beta2.Job> updateJobCallable()
updateJobCallable
in class JobControllerStub
public UnaryCallable<com.google.cloud.dataproc.v1beta2.CancelJobRequest,com.google.cloud.dataproc.v1beta2.Job> cancelJobCallable()
cancelJobCallable
in class JobControllerStub
public UnaryCallable<com.google.cloud.dataproc.v1beta2.DeleteJobRequest,Empty> deleteJobCallable()
deleteJobCallable
in class JobControllerStub
public final void close()
close
in interface AutoCloseable
close
in class JobControllerStub
public void shutdown()
public boolean isShutdown()
public boolean isTerminated()
public void shutdownNow()
public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException
InterruptedException
Copyright © 2019 Google LLC. All rights reserved.