Package com.google.dataflow.v1beta3

Class JobsV1Beta3Grpc.JobsV1Beta3FutureStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractFutureStub<JobsV1Beta3Grpc.JobsV1Beta3FutureStub>
com.google.dataflow.v1beta3.JobsV1Beta3Grpc.JobsV1Beta3FutureStub
Enclosing class:
JobsV1Beta3Grpc
public static final class JobsV1Beta3Grpc.JobsV1Beta3FutureStub extends io.grpc.stub.AbstractFutureStub<JobsV1Beta3Grpc.JobsV1Beta3FutureStub>
A stub to allow clients to do ListenableFuture-style 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
    com.google.common.util.concurrent.ListenableFuture<ListJobsResponse>
    aggregatedListJobs(ListJobsRequest request)
    List the jobs of a project across all regions.
    protected JobsV1Beta3Grpc.JobsV1Beta3FutureStub
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    com.google.common.util.concurrent.ListenableFuture<CheckActiveJobsResponse>
    checkActiveJobs(CheckActiveJobsRequest request)
    Check for existence of active jobs in the given project across all regions.
    com.google.common.util.concurrent.ListenableFuture<Job>
    createJob(CreateJobRequest request)
    Creates a Dataflow job.
    com.google.common.util.concurrent.ListenableFuture<Job>
    getJob(GetJobRequest request)
    Gets the state of the specified Cloud Dataflow job.
    com.google.common.util.concurrent.ListenableFuture<ListJobsResponse>
    listJobs(ListJobsRequest request)
    List the jobs of a project.
    com.google.common.util.concurrent.ListenableFuture<Snapshot>
    snapshotJob(SnapshotJobRequest request)
    Snapshot the state of a streaming job.
    com.google.common.util.concurrent.ListenableFuture<Job>
    updateJob(UpdateJobRequest request)
    Updates the state of an existing Cloud Dataflow job.

    Methods inherited from class io.grpc.stub.AbstractFutureStub

    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.JobsV1Beta3FutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<JobsV1Beta3Grpc.JobsV1Beta3FutureStub>

    • createJob

      public com.google.common.util.concurrent.ListenableFuture<Job> createJob(CreateJobRequest request)
       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 com.google.common.util.concurrent.ListenableFuture<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]
 (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 com.google.common.util.concurrent.ListenableFuture<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]
 (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 com.google.common.util.concurrent.ListenableFuture<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]
 (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 com.google.common.util.concurrent.ListenableFuture<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.

    • checkActiveJobs

      public com.google.common.util.concurrent.ListenableFuture<CheckActiveJobsResponse> checkActiveJobs(CheckActiveJobsRequest request)
       Check for existence of active jobs in the given project across all regions.

    • snapshotJob

      public com.google.common.util.concurrent.ListenableFuture<Snapshot> snapshotJob(SnapshotJobRequest request)
       Snapshot the state of a streaming job.