Class JobsV1Beta3Grpc.JobsV1Beta3Stub (0.58.0)

Version latest

• 0.58.0 (latest)
• 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.JobsV1Beta3Stub extends AbstractAsyncStub<JobsV1Beta3Grpc.JobsV1Beta3Stub>

A stub to allow clients to do asynchronous 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.AbstractAsyncStub > JobsV1Beta3Grpc.JobsV1Beta3Stub

Inherited Members

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractAsyncStub.<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()

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, StreamObserver<ListJobsResponse> responseObserver)

public void aggregatedListJobs(ListJobsRequest request, StreamObserver<ListJobsResponse> responseObserver)

List the jobs of a project across all regions.

Parameters
Name	Description
request	ListJobsRequest
responseObserver	io.grpc.stub.StreamObserver<ListJobsResponse>

build(Channel channel, CallOptions callOptions)

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

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

Returns
Type	Description
JobsV1Beta3Grpc.JobsV1Beta3Stub

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

checkActiveJobs(CheckActiveJobsRequest request, StreamObserver<CheckActiveJobsResponse> responseObserver)

public void checkActiveJobs(CheckActiveJobsRequest request, StreamObserver<CheckActiveJobsResponse> responseObserver)

Check for existence of active jobs in the given project across all regions.

Parameters
Name	Description
request	CheckActiveJobsRequest
responseObserver	io.grpc.stub.StreamObserver<CheckActiveJobsResponse>

createJob(CreateJobRequest request, StreamObserver<Job> responseObserver)

public void createJob(CreateJobRequest request, StreamObserver<Job> responseObserver)

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.

Parameters
Name	Description
request	CreateJobRequest
responseObserver	io.grpc.stub.StreamObserver<Job>

getJob(GetJobRequest request, StreamObserver<Job> responseObserver)

public void getJob(GetJobRequest request, StreamObserver<Job> responseObserver)

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.

Parameters
Name	Description
request	GetJobRequest
responseObserver	io.grpc.stub.StreamObserver<Job>

listJobs(ListJobsRequest request, StreamObserver<ListJobsResponse> responseObserver)

public void listJobs(ListJobsRequest request, StreamObserver<ListJobsResponse> responseObserver)

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.

Parameters
Name	Description
request	ListJobsRequest
responseObserver	io.grpc.stub.StreamObserver<ListJobsResponse>

snapshotJob(SnapshotJobRequest request, StreamObserver<Snapshot> responseObserver)

public void snapshotJob(SnapshotJobRequest request, StreamObserver<Snapshot> responseObserver)

Snapshot the state of a streaming job.

Parameters
Name	Description
request	SnapshotJobRequest
responseObserver	io.grpc.stub.StreamObserver<Snapshot>

updateJob(UpdateJobRequest request, StreamObserver<Job> responseObserver)

public void updateJob(UpdateJobRequest request, StreamObserver<Job> responseObserver)

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.

Parameters
Name	Description
request	UpdateJobRequest
responseObserver	io.grpc.stub.StreamObserver<Job>