Dataflow v1beta3 API - Class JobsV1Beta3.JobsV1Beta3Base (2.0.0-beta07)

[BindServiceMethod(typeof(JobsV1Beta3), "BindService")]
public abstract class JobsV1Beta3.JobsV1Beta3Base

Reference documentation and code samples for the Dataflow v1beta3 API class JobsV1Beta3.JobsV1Beta3Base.

Base class for server-side implementations of JobsV1Beta3

Inheritance

object > JobsV1Beta3.JobsV1Beta3Base

Namespace

Google.Cloud.Dataflow.V1Beta3

Assembly

Google.Cloud.Dataflow.V1Beta3.dll

Methods

AggregatedListJobs(ListJobsRequest, ServerCallContext)

public virtual Task<ListJobsResponse> AggregatedListJobs(ListJobsRequest request, ServerCallContext context)

List the jobs of a project across all regions.

Parameters
Name Description
request ListJobsRequest

The request received from the client.

context ServerCallContext

The context of the server-side call handler being invoked.

Returns
Type Description
TaskListJobsResponse

The response to send back to the client (wrapped by a task).

CheckActiveJobs(CheckActiveJobsRequest, ServerCallContext)

public virtual Task<CheckActiveJobsResponse> CheckActiveJobs(CheckActiveJobsRequest request, ServerCallContext context)

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

Parameters
Name Description
request CheckActiveJobsRequest

The request received from the client.

context ServerCallContext

The context of the server-side call handler being invoked.

Returns
Type Description
TaskCheckActiveJobsResponse

The response to send back to the client (wrapped by a task).

CreateJob(CreateJobRequest, ServerCallContext)

public virtual Task<Job> CreateJob(CreateJobRequest request, ServerCallContext context)

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

The request received from the client.

context ServerCallContext

The context of the server-side call handler being invoked.

Returns
Type Description
TaskJob

The response to send back to the client (wrapped by a task).

GetJob(GetJobRequest, ServerCallContext)

public virtual Task<Job> GetJob(GetJobRequest request, ServerCallContext context)

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

The request received from the client.

context ServerCallContext

The context of the server-side call handler being invoked.

Returns
Type Description
TaskJob

The response to send back to the client (wrapped by a task).

ListJobs(ListJobsRequest, ServerCallContext)

public virtual Task<ListJobsResponse> ListJobs(ListJobsRequest request, ServerCallContext context)

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

The request received from the client.

context ServerCallContext

The context of the server-side call handler being invoked.

Returns
Type Description
TaskListJobsResponse

The response to send back to the client (wrapped by a task).

SnapshotJob(SnapshotJobRequest, ServerCallContext)

public virtual Task<Snapshot> SnapshotJob(SnapshotJobRequest request, ServerCallContext context)

Snapshot the state of a streaming job.

Parameters
Name Description
request SnapshotJobRequest

The request received from the client.

context ServerCallContext

The context of the server-side call handler being invoked.

Returns
Type Description
TaskSnapshot

The response to send back to the client (wrapped by a task).

UpdateJob(UpdateJobRequest, ServerCallContext)

public virtual Task<Job> UpdateJob(UpdateJobRequest request, ServerCallContext context)

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

The request received from the client.

context ServerCallContext

The context of the server-side call handler being invoked.

Returns
Type Description
TaskJob

The response to send back to the client (wrapped by a task).