public static interface JobsV1Beta3Grpc.AsyncService
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.
Methods
aggregatedListJobs(ListJobsRequest request, StreamObserver<ListJobsResponse> responseObserver)
public default 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> |
checkActiveJobs(CheckActiveJobsRequest request, StreamObserver<CheckActiveJobsResponse> responseObserver)
public default 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 default 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 default 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 default 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 default 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 default 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> |