com.google.api.services.dataproc.v1beta2

Class Dataproc.Projects.Regions.Jobs

java.lang.Object

com.google.api.services.dataproc.v1beta2.Dataproc.Projects.Regions.Jobs

Enclosing class:

Dataproc.Projects.Regions

public class Dataproc.Projects.Regions.Jobs
extends Object

The "jobs" collection of methods.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Dataproc.Projects.Regions.Jobs.Cancel
class	Dataproc.Projects.Regions.Jobs.Delete
class	Dataproc.Projects.Regions.Jobs.Get
class	Dataproc.Projects.Regions.Jobs.GetIamPolicy
class	Dataproc.Projects.Regions.Jobs.List
class	Dataproc.Projects.Regions.Jobs.Patch
class	Dataproc.Projects.Regions.Jobs.SetIamPolicy
class	Dataproc.Projects.Regions.Jobs.Submit
class	Dataproc.Projects.Regions.Jobs.SubmitAsOperation
class	Dataproc.Projects.Regions.Jobs.TestIamPermissions

Constructor Summary

Constructors

Constructor and Description
Jobs()

Method Summary

Modifier and Type	Method and Description
Dataproc.Projects.Regions.Jobs.Cancel	cancel(String projectId, String region, String jobId, CancelJobRequest content) Starts a job cancellation request.
Dataproc.Projects.Regions.Jobs.Delete	delete(String projectId, String region, String jobId) Deletes the job from the project.
Dataproc.Projects.Regions.Jobs.Get	get(String projectId, String region, String jobId) Gets the resource representation for a job in a project.
Dataproc.Projects.Regions.Jobs.GetIamPolicy	getIamPolicy(String resource) Gets the access control policy for a resource.
Dataproc.Projects.Regions.Jobs.List	list(String projectId, String region) Lists regions/{region}/jobs in a project.
Dataproc.Projects.Regions.Jobs.Patch	patch(String projectId, String region, String jobId, Job content) Updates a job in a project.
Dataproc.Projects.Regions.Jobs.SetIamPolicy	setIamPolicy(String resource, SetIamPolicyRequest content) Sets the access control policy on the specified resource.
Dataproc.Projects.Regions.Jobs.Submit	submit(String projectId, String region, SubmitJobRequest content) Submits a job to a cluster.
Dataproc.Projects.Regions.Jobs.SubmitAsOperation	submitAsOperation(String projectId, String region, SubmitJobRequest content) Submits job to a cluster.
Dataproc.Projects.Regions.Jobs.TestIamPermissions	testIamPermissions(String resource, TestIamPermissionsRequest content) Returns permissions that a caller has on the specified resource.

Methods inherited from class java.lang.Object

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

Constructor Detail

Jobs

public Jobs()

Method Detail

cancel

public Dataproc.Projects.Regions.Jobs.Cancel cancel(String projectId,
                                                    String region,
                                                    String jobId,
                                                    CancelJobRequest content)
                                             throws IOException

Starts a job cancellation request. To access the job resource after cancellation, call regions/{region}/jobs.list (https://cloud.google.com/dataproc/docs/reference/rest/v1beta2/projects.regions.jobs/list) or regions/{region}/jobs.get (https://cloud.google.com/dataproc/docs/reference/rest/v1beta2/projects.regions.jobs/get). Create a request for the method "jobs.cancel". This request holds the parameters needed by the dataproc server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

projectId - Required. The ID of the Google Cloud Platform project that the job belongs to.

region - Required. The Dataproc region in which to handle the request.

jobId - Required. The job ID.

content - the CancelJobRequest

Returns:

the request

Throws:

IOException

delete

public Dataproc.Projects.Regions.Jobs.Delete delete(String projectId,
                                                    String region,
                                                    String jobId)
                                             throws IOException

Deletes the job from the project. If the job is active, the delete fails, and the response returns FAILED_PRECONDITION. Create a request for the method "jobs.delete". This request holds the parameters needed by the dataproc server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

projectId - Required. The ID of the Google Cloud Platform project that the job belongs to.

region - Required. The Dataproc region in which to handle the request.

jobId - Required. The job ID.

Returns:

the request

Throws:

IOException

get

public Dataproc.Projects.Regions.Jobs.Get get(String projectId,
                                              String region,
                                              String jobId)
                                       throws IOException

Gets the resource representation for a job in a project. Create a request for the method "jobs.get". This request holds the parameters needed by the dataproc server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

projectId - Required. The ID of the Google Cloud Platform project that the job belongs to.

region - Required. The Dataproc region in which to handle the request.

jobId - Required. The job ID.

Returns:

the request

Throws:

IOException

getIamPolicy

public Dataproc.Projects.Regions.Jobs.GetIamPolicy getIamPolicy(String resource)
                                                         throws IOException

Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Create a request for the method "jobs.getIamPolicy". This request holds the parameters needed by the dataproc server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

resource - REQUIRED: The resource for which the policy is being requested. See the operation documentation for the appropriate value for this field.

Returns:

the request

Throws:

IOException

list

public Dataproc.Projects.Regions.Jobs.List list(String projectId,
                                                String region)
                                         throws IOException

Lists regions/{region}/jobs in a project. Create a request for the method "jobs.list". This request holds the parameters needed by the dataproc server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

projectId - Required. The ID of the Google Cloud Platform project that the job belongs to.

region - Required. The Dataproc region in which to handle the request.

Returns:

the request

Throws:

IOException

patch

public Dataproc.Projects.Regions.Jobs.Patch patch(String projectId,
                                                  String region,
                                                  String jobId,
                                                  Job content)
                                           throws IOException

Updates a job in a project. Create a request for the method "jobs.patch". This request holds the parameters needed by the dataproc server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

projectId - Required. The ID of the Google Cloud Platform project that the job belongs to.

region - Required. The Dataproc region in which to handle the request.

jobId - Required. The job ID.

content - the Job

Returns:

the request

Throws:

IOException

setIamPolicy

public Dataproc.Projects.Regions.Jobs.SetIamPolicy setIamPolicy(String resource,
                                                                SetIamPolicyRequest content)
                                                         throws IOException

Sets the access control policy on the specified resource. Replaces any existing policy.Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIED errors. Create a request for the method "jobs.setIamPolicy". This request holds the parameters needed by the dataproc server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

resource - REQUIRED: The resource for which the policy is being specified. See the operation documentation for the appropriate value for this field.

content - the SetIamPolicyRequest

Returns:

the request

Throws:

IOException

submit

public Dataproc.Projects.Regions.Jobs.Submit submit(String projectId,
                                                    String region,
                                                    SubmitJobRequest content)
                                             throws IOException

Submits a job to a cluster. Create a request for the method "jobs.submit". This request holds the parameters needed by the dataproc server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

projectId - Required. The ID of the Google Cloud Platform project that the job belongs to.

region - Required. The Dataproc region in which to handle the request.

content - the SubmitJobRequest

Returns:

the request

Throws:

IOException

submitAsOperation

public Dataproc.Projects.Regions.Jobs.SubmitAsOperation submitAsOperation(String projectId,
                                                                          String region,
                                                                          SubmitJobRequest content)
                                                                   throws IOException

Submits job to a cluster. Create a request for the method "jobs.submitAsOperation". This request holds the parameters needed by the dataproc server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

projectId - Required. The ID of the Google Cloud Platform project that the job belongs to.

region - Required. The Dataproc region in which to handle the request.

content - the SubmitJobRequest

Returns:

the request

Throws:

IOException

testIamPermissions

public Dataproc.Projects.Regions.Jobs.TestIamPermissions testIamPermissions(String resource,
                                                                            TestIamPermissionsRequest content)
                                                                     throws IOException

Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Create a request for the method "jobs.testIamPermissions". This request holds the parameters needed by the dataproc server. After setting any optional parameters, call the AbstractGoogleClientRequest.execute() method to invoke the remote operation.

Parameters:

resource - REQUIRED: The resource for which the policy detail is being requested. See the operation documentation for the appropriate value for this field.

content - the TestIamPermissionsRequest

Returns:

the request

Throws:

IOException