Class JobsV1Beta3Grpc.JobsV1Beta3BlockingV2Stub (0.99.0)

0.99.0 (latest) 0.98.0 0.97.0 0.95.0 0.92.0 0.91.0 0.89.0 0.87.0 0.86.0 0.85.0 0.84.0 0.82.0 0.80.0 0.79.0 0.78.0 0.77.0 0.76.0 0.74.0 0.72.0 0.71.0 0.68.0 0.67.0 0.66.0 0.64.0 0.63.0 0.62.0 0.61.0 0.60.0 0.59.0 0.58.0 0.57.0 0.56.0 0.55.0 0.53.0 0.52.0 0.51.0 0.50.0 0.49.0 0.48.0 0.47.0 0.46.0 0.45.0 0.44.0 0.43.0 0.41.0 0.40.0 0.39.0 0.38.0 0.37.0 0.36.0 0.35.0 0.34.0 0.33.0 0.32.0 0.31.0 0.28.0 0.27.0 0.26.0 0.25.0 0.24.0 0.23.0 0.22.0 0.21.0 0.20.0 0.19.0 0.18.0 0.17.0 0.16.0 0.15.0 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.5.0

public static final class JobsV1Beta3Grpc.JobsV1Beta3BlockingV2Stub extends AbstractBlockingStub<JobsV1Beta3Grpc.JobsV1Beta3BlockingV2Stub>

A stub to allow clients to do synchronous rpc calls to service JobsV1Beta3.

Provides a method to create and modify Dataflow jobs. A Job is a multi-stage computation graph run by the Dataflow service.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractBlockingStub > JobsV1Beta3Grpc.JobsV1Beta3BlockingV2Stub

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(java.time.Duration)

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()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

aggregatedListJobs(ListJobsRequest request)

public ListJobsResponse aggregatedListJobs(ListJobsRequest request)

List the jobs of a project across all regions. Note: This method doesn't support filtering the list of jobs by name.

Parameter
Name	Description
request	ListJobsRequest

Returns
Type	Description
ListJobsResponse

Exceptions
Type	Description
io.grpc.StatusException

build(Channel channel, CallOptions callOptions)

protected JobsV1Beta3Grpc.JobsV1Beta3BlockingV2Stub build(Channel channel, CallOptions callOptions)

Parameters
Name	Description
channel	io.grpc.Channel
callOptions	io.grpc.CallOptions

Returns
Type	Description
JobsV1Beta3Grpc.JobsV1Beta3BlockingV2Stub

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.

Parameter
Name	Description
request	CheckActiveJobsRequest

Returns
Type	Description
CheckActiveJobsResponse

Exceptions
Type	Description
io.grpc.StatusException

createJob(CreateJobRequest request)

public Job createJob(CreateJobRequest request)

Creates a 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. Do not enter confidential information when you supply string values using the API.

Parameter
Name	Description
request	CreateJobRequest

Returns
Type	Description
Job

Exceptions
Type	Description
io.grpc.StatusException

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.

Parameter
Name	Description
request	GetJobRequest

Returns
Type	Description
Job

Exceptions
Type	Description
io.grpc.StatusException

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, because you can only get the list of jobs that are running in us-central1. projects.locations.jobs.list and projects.jobs.list support filtering the list of jobs by name. Filtering by name isn't supported by projects.jobs.aggregated.

Parameter
Name	Description
request	ListJobsRequest

Returns
Type	Description
ListJobsResponse

Exceptions
Type	Description
io.grpc.StatusException

snapshotJob(SnapshotJobRequest request)

public Snapshot snapshotJob(SnapshotJobRequest request)

Snapshot the state of a streaming job.

Parameter
Name	Description
request	SnapshotJobRequest

Returns
Type	Description
Snapshot

Exceptions
Type	Description
io.grpc.StatusException

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.

Parameter
Name	Description
request	UpdateJobRequest

Returns
Type	Description
Job

Exceptions
Type	Description
io.grpc.StatusException