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.JobsV1Beta3StubMethods
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 |
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> |