public static final class JobsV1Beta3Grpc.JobsV1Beta3BlockingStub extends AbstractBlockingStub<JobsV1Beta3Grpc.JobsV1Beta3BlockingStub>
A stub to allow clients to do synchronous 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.AbstractBlockingStub >
JobsV1Beta3Grpc.JobsV1Beta3BlockingStub
Inherited Members
io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractBlockingStub.<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.withOnReadyThreshold(int)
io.grpc.stub.AbstractStub.withWaitForReady()
Methods
aggregatedListJobs(ListJobsRequest request)
public ListJobsResponse aggregatedListJobs(ListJobsRequest request)
List the jobs of a project across all regions.
build(Channel channel, CallOptions callOptions)
protected JobsV1Beta3Grpc.JobsV1Beta3BlockingStub 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 CheckActiveJobsResponse checkActiveJobs(CheckActiveJobsRequest request)
Check for existence of active jobs in the given project across all regions.
createJob(CreateJobRequest request)
public 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 |
Job |
|
getJob(GetJobRequest request)
public 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 |
Job |
|
listJobs(ListJobsRequest request)
public 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
.
snapshotJob(SnapshotJobRequest request)
public Snapshot snapshotJob(SnapshotJobRequest request)
Snapshot the state of a streaming job.
updateJob(UpdateJobRequest request)
public 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 |
Job |
|