public static final class JobsV1Beta3Grpc.JobsV1Beta3FutureStub extends AbstractFutureStub<JobsV1Beta3Grpc.JobsV1Beta3FutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service JobsV1Beta3.
Provides a method to create and modify Google Cloud Dataflow jobs.
A Job is a multi-stage computation graph run by the Cloud Dataflow service.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractFutureStub >
JobsV1Beta3Grpc.JobsV1Beta3FutureStub
Inherited Members
io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.getCallOptions()
io.grpc.stub.AbstractStub.getChannel()
io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)
io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)
io.grpc.stub.AbstractStub.withCompression(java.lang.String)
io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)
io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)
io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)
io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)
io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)
io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)
io.grpc.stub.AbstractStub.withWaitForReady()
Methods
aggregatedListJobs(ListJobsRequest request)
public ListenableFuture<ListJobsResponse> aggregatedListJobs(ListJobsRequest request)
List the jobs of a project across all regions.
| Returns |
|---|
| Type | Description |
com.google.common.util.concurrent.ListenableFuture<ListJobsResponse> | |
build(Channel channel, CallOptions callOptions)
protected JobsV1Beta3Grpc.JobsV1Beta3FutureStub build(Channel channel, CallOptions callOptions)
| Parameters |
|---|
| Name | Description |
channel | io.grpc.Channel
|
callOptions | io.grpc.CallOptions
|
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
checkActiveJobs(CheckActiveJobsRequest request)
public ListenableFuture<CheckActiveJobsResponse> checkActiveJobs(CheckActiveJobsRequest request)
Check for existence of active jobs in the given project across all regions.
createJob(CreateJobRequest request)
public ListenableFuture<Job> createJob(CreateJobRequest request)
Creates a Cloud Dataflow job.
To create a job, we recommend using projects.locations.jobs.create with a
regional endpoint. Using
projects.jobs.create is not recommended, as your job will always start
in us-central1.
| Returns |
|---|
| Type | Description |
com.google.common.util.concurrent.ListenableFuture<Job> | |
getJob(GetJobRequest request)
public ListenableFuture<Job> getJob(GetJobRequest request)
Gets the state of the specified Cloud Dataflow job.
To get the state of a job, we recommend using projects.locations.jobs.get
with a regional endpoint. Using
projects.jobs.get is not recommended, as you can only get the state of
jobs that are running in us-central1.
| Returns |
|---|
| Type | Description |
com.google.common.util.concurrent.ListenableFuture<Job> | |
listJobs(ListJobsRequest request)
public ListenableFuture<ListJobsResponse> listJobs(ListJobsRequest request)
List the jobs of a project.
To list the jobs of a project in a region, we recommend using
projects.locations.jobs.list with a regional endpoint. To
list the all jobs across all regions, use projects.jobs.aggregated. Using
projects.jobs.list is not recommended, as you can only get the list of
jobs that are running in us-central1.
| Returns |
|---|
| Type | Description |
com.google.common.util.concurrent.ListenableFuture<ListJobsResponse> | |
snapshotJob(SnapshotJobRequest request)
public ListenableFuture<Snapshot> snapshotJob(SnapshotJobRequest request)
Snapshot the state of a streaming job.
| Returns |
|---|
| Type | Description |
com.google.common.util.concurrent.ListenableFuture<Snapshot> | |
updateJob(UpdateJobRequest request)
public ListenableFuture<Job> updateJob(UpdateJobRequest request)
Updates the state of an existing Cloud Dataflow job.
To update the state of an existing job, we recommend using
projects.locations.jobs.update with a regional endpoint. Using
projects.jobs.update is not recommended, as you can only update the state
of jobs that are running in us-central1.
| Returns |
|---|
| Type | Description |
com.google.common.util.concurrent.ListenableFuture<Job> | |
