Package com.google.dataflow.v1beta3

Class JobsV1Beta3Grpc.JobsV1Beta3Stub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<JobsV1Beta3Grpc.JobsV1Beta3Stub>
com.google.dataflow.v1beta3.JobsV1Beta3Grpc.JobsV1Beta3Stub
Enclosing class:
JobsV1Beta3Grpc
public static final class JobsV1Beta3Grpc.JobsV1Beta3Stub extends io.grpc.stub.AbstractAsyncStub<JobsV1Beta3Grpc.JobsV1Beta3Stub>
A stub to allow clients to do asynchronous 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.

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

    io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    aggregatedListJobs(ListJobsRequest request, io.grpc.stub.StreamObserver<ListJobsResponse> responseObserver)
    List the jobs of a project across all regions.
    protected JobsV1Beta3Grpc.JobsV1Beta3Stub
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    void
    checkActiveJobs(CheckActiveJobsRequest request, io.grpc.stub.StreamObserver<CheckActiveJobsResponse> responseObserver)
    Check for existence of active jobs in the given project across all regions.
    void
    createJob(CreateJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
    Creates a Dataflow job.
    void
    getJob(GetJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
    Gets the state of the specified Cloud Dataflow job.
    void
    listJobs(ListJobsRequest request, io.grpc.stub.StreamObserver<ListJobsResponse> responseObserver)
    List the jobs of a project.
    void
    snapshotJob(SnapshotJobRequest request, io.grpc.stub.StreamObserver<Snapshot> responseObserver)
    Snapshot the state of a streaming job.
    void
    updateJob(UpdateJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
    Updates the state of an existing Cloud Dataflow job.

    Methods inherited from class io.grpc.stub.AbstractAsyncStub

    newStub, newStub

    Methods inherited from class io.grpc.stub.AbstractStub

    getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • build

      protected JobsV1Beta3Grpc.JobsV1Beta3Stub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<JobsV1Beta3Grpc.JobsV1Beta3Stub>

    • createJob

      public void createJob(CreateJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
       Creates a Dataflow job.
 To create a job, we recommend using `projects.locations.jobs.create` with a
 [regional endpoint]
 (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). 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.

    • getJob

      public void getJob(GetJobRequest request, io.grpc.stub.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]
 (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using
 `projects.jobs.get` is not recommended, as you can only get the state of
 jobs that are running in `us-central1`.

    • updateJob

      public void updateJob(UpdateJobRequest request, io.grpc.stub.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]
 (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using
 `projects.jobs.update` is not recommended, as you can only update the state
 of jobs that are running in `us-central1`.

    • listJobs

      public void listJobs(ListJobsRequest request, io.grpc.stub.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]
 (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). 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`.

    • aggregatedListJobs

      public void aggregatedListJobs(ListJobsRequest request, io.grpc.stub.StreamObserver<ListJobsResponse> responseObserver)
       List the jobs of a project across all regions.
 **Note:** This method doesn't support filtering the list of
 jobs by name.

    • checkActiveJobs

      public void checkActiveJobs(CheckActiveJobsRequest request, io.grpc.stub.StreamObserver<CheckActiveJobsResponse> responseObserver)
       Check for existence of active jobs in the given project across all regions.

    • snapshotJob

      public void snapshotJob(SnapshotJobRequest request, io.grpc.stub.StreamObserver<Snapshot> responseObserver)
       Snapshot the state of a streaming job.