class ProjectsJobs extends Resource (View source)

The "jobs" collection of methods.

Typical usage is:

 $dataflowService = new Google\Service\Dataflow(...);
 $jobs = $dataflowService->projects_jobs;

Methods

aggregated(string $projectId, array $optParams = [])

List the jobs of a project across all regions. Note: This method doesn't support filtering the list of jobs by name. (jobs.aggregated)

Job
create(string $projectId, Job $postBody, array $optParams = [])

Creates a Cloud 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. (jobs.create)

Job
get(string $projectId, string $jobId, array $optParams = [])

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. (jobs.get)

getMetrics(string $projectId, string $jobId, array $optParams = [])

Request the job status. To request the status of a job, we recommend using projects.locations.jobs.getMetrics with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.getMetrics is not recommended, as you can only request the status of jobs that are running in us-central1. (jobs.getMetrics)

listProjectsJobs(string $projectId, array $optParams = [])

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. (jobs.listProjectsJobs)

snapshot(string $projectId, string $jobId, SnapshotJobRequest $postBody, array $optParams = [])

Snapshot the state of a streaming job. (jobs.snapshot)

Job
update(string $projectId, string $jobId, Job $postBody, array $optParams = [])

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. (jobs.update)

Details

ListJobsResponse aggregated(string $projectId, array $optParams = [])

List the jobs of a project across all regions. Note: This method doesn't support filtering the list of jobs by name. (jobs.aggregated)

Parameters

string $projectId

The project which owns the jobs.

array $optParams

Optional parameters.

Return Value

ListJobsResponse

Exceptions

Exception

Job create(string $projectId, Job $postBody, array $optParams = [])

Creates a Cloud 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. (jobs.create)

Parameters

string $projectId

The ID of the Cloud Platform project that the job belongs to.

Job $postBody
array $optParams

Optional parameters.

Return Value

Job

Exceptions

Exception

Job get(string $projectId, string $jobId, array $optParams = [])

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. (jobs.get)

Parameters

string $projectId

The ID of the Cloud Platform project that the job belongs to.

string $jobId

The job ID.

array $optParams

Optional parameters.

Return Value

Job

Exceptions

Exception

JobMetrics getMetrics(string $projectId, string $jobId, array $optParams = [])

Request the job status. To request the status of a job, we recommend using projects.locations.jobs.getMetrics with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.getMetrics is not recommended, as you can only request the status of jobs that are running in us-central1. (jobs.getMetrics)

Parameters

string $projectId

A project id.

string $jobId

The job to get metrics for.

array $optParams

Optional parameters.

Return Value

JobMetrics

Exceptions

Exception

ListJobsResponse listProjectsJobs(string $projectId, array $optParams = [])

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. (jobs.listProjectsJobs)

Parameters

string $projectId

The project which owns the jobs.

array $optParams

Optional parameters.

Return Value

ListJobsResponse

Exceptions

Exception

Snapshot snapshot(string $projectId, string $jobId, SnapshotJobRequest $postBody, array $optParams = [])

Snapshot the state of a streaming job. (jobs.snapshot)

Parameters

string $projectId

The project which owns the job to be snapshotted.

string $jobId

The job to be snapshotted.

SnapshotJobRequest $postBody
array $optParams

Optional parameters.

Return Value

Snapshot

Exceptions

Exception

Job update(string $projectId, string $jobId, Job $postBody, array $optParams = [])

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. (jobs.update)

Parameters

string $projectId

The ID of the Cloud Platform project that the job belongs to.

string $jobId

The job ID.

Job $postBody
array $optParams

Optional parameters.

Return Value

Job

Exceptions

Exception