Class v1.JobControllerClient (4.1.1)

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The ID of the Google Cloud Platform project that the job
   *  belongs to.
   */
  // const projectId = 'abc123'
  /**
   *  Required. The Dataproc region in which to handle the request.
   */
  // const region = 'us-central1'
  /**
   *  Required. The job ID.
   */
  // const jobId = 'abc123'

  // Imports the Dataproc library
  const {JobControllerClient} = require('@google-cloud/dataproc').v1;

  // Instantiates a client
  const dataprocClient = new JobControllerClient();

  async function callCancelJob() {
    // Construct request
    const request = {
      projectId,
      region,
      jobId,
    };

    // Run request
    const response = await dataprocClient.cancelJob(request);
    console.log(response);
  }

  callCancelJob();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The ID of the Google Cloud Platform project that the job
   *  belongs to.
   */
  // const projectId = 'abc123'
  /**
   *  Required. The Dataproc region in which to handle the request.
   */
  // const region = 'us-central1'
  /**
   *  Required. The job resource.
   */
  // const job = {}
  /**
   *  Optional. A unique id used to identify the request. If the server
   *  receives two
   *  SubmitJobRequest (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#google.cloud.dataproc.v1.SubmitJobRequest)s
   *  with the same id, then the second request will be ignored and the
   *  first Job google.cloud.dataproc.v1.Job  created and stored in the backend
   *  is returned.
   *  It is recommended to always set this value to a
   *  UUID (https://en.wikipedia.org/wiki/Universally_unique_identifier).
   *  The id must contain only letters (a-z, A-Z), numbers (0-9),
   *  underscores (_), and hyphens (-). The maximum length is 40 characters.
   */
  // const requestId = 'abc123'

  // Imports the Dataproc library
  const {JobControllerClient} = require('@google-cloud/dataproc').v1;

  // Instantiates a client
  const dataprocClient = new JobControllerClient();

  async function callSubmitJobAsOperation() {
    // Construct request
    const request = {
      projectId,
      region,
      job,
    };

    // Run request
    const [operation] = await dataprocClient.submitJobAsOperation(request);
    const [response] = await operation.promise();
    console.log(response);
  }

  callSubmitJobAsOperation();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The ID of the Google Cloud Platform project that the job
   *  belongs to.
   */
  // const projectId = 'abc123'
  /**
   *  Required. The Dataproc region in which to handle the request.
   */
  // const region = 'us-central1'
  /**
   *  Required. The job ID.
   */
  // const jobId = 'abc123'

  // Imports the Dataproc library
  const {JobControllerClient} = require('@google-cloud/dataproc').v1;

  // Instantiates a client
  const dataprocClient = new JobControllerClient();

  async function callDeleteJob() {
    // Construct request
    const request = {
      projectId,
      region,
      jobId,
    };

    // Run request
    const response = await dataprocClient.deleteJob(request);
    console.log(response);
  }

  callDeleteJob();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The ID of the Google Cloud Platform project that the job
   *  belongs to.
   */
  // const projectId = 'abc123'
  /**
   *  Required. The Dataproc region in which to handle the request.
   */
  // const region = 'us-central1'
  /**
   *  Required. The job ID.
   */
  // const jobId = 'abc123'

  // Imports the Dataproc library
  const {JobControllerClient} = require('@google-cloud/dataproc').v1;

  // Instantiates a client
  const dataprocClient = new JobControllerClient();

  async function callGetJob() {
    // Construct request
    const request = {
      projectId,
      region,
      jobId,
    };

    // Run request
    const response = await dataprocClient.getJob(request);
    console.log(response);
  }

  callGetJob();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The ID of the Google Cloud Platform project that the job
   *  belongs to.
   */
  // const projectId = 'abc123'
  /**
   *  Required. The Dataproc region in which to handle the request.
   */
  // const region = 'us-central1'
  /**
   *  Optional. The number of results to return in each response.
   */
  // const pageSize = 1234
  /**
   *  Optional. The page token, returned by a previous call, to request the
   *  next page of results.
   */
  // const pageToken = 'abc123'
  /**
   *  Optional. If set, the returned jobs list includes only jobs that were
   *  submitted to the named cluster.
   */
  // const clusterName = 'abc123'
  /**
   *  Optional. Specifies enumerated categories of jobs to list.
   *  (default = match ALL jobs).
   *  If `filter` is provided, `jobStateMatcher` will be ignored.
   */
  // const jobStateMatcher = {}
  /**
   *  Optional. A filter constraining the jobs to list. Filters are
   *  case-sensitive and have the following syntax:
   *  field = value  AND field = value   ...
   *  where **field** is `status.state` or `labels.[KEY]`, and `[KEY]` is a label
   *  key. **value** can be `*` to match all values.
   *  `status.state` can be either `ACTIVE` or `NON_ACTIVE`.
   *  Only the logical `AND` operator is supported; space-separated items are
   *  treated as having an implicit `AND` operator.
   *  Example filter:
   *  status.state = ACTIVE AND labels.env = staging AND labels.starred = *
   */
  // const filter = 'abc123'

  // Imports the Dataproc library
  const {JobControllerClient} = require('@google-cloud/dataproc').v1;

  // Instantiates a client
  const dataprocClient = new JobControllerClient();

  async function callListJobs() {
    // Construct request
    const request = {
      projectId,
      region,
    };

    // Run request
    const iterable = await dataprocClient.listJobsAsync(request);
    for await (const response of iterable) {
        console.log(response);
    }
  }

  callListJobs();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The ID of the Google Cloud Platform project that the job
   *  belongs to.
   */
  // const projectId = 'abc123'
  /**
   *  Required. The Dataproc region in which to handle the request.
   */
  // const region = 'us-central1'
  /**
   *  Required. The job resource.
   */
  // const job = {}
  /**
   *  Optional. A unique id used to identify the request. If the server
   *  receives two
   *  SubmitJobRequest (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#google.cloud.dataproc.v1.SubmitJobRequest)s
   *  with the same id, then the second request will be ignored and the
   *  first Job google.cloud.dataproc.v1.Job  created and stored in the backend
   *  is returned.
   *  It is recommended to always set this value to a
   *  UUID (https://en.wikipedia.org/wiki/Universally_unique_identifier).
   *  The id must contain only letters (a-z, A-Z), numbers (0-9),
   *  underscores (_), and hyphens (-). The maximum length is 40 characters.
   */
  // const requestId = 'abc123'

  // Imports the Dataproc library
  const {JobControllerClient} = require('@google-cloud/dataproc').v1;

  // Instantiates a client
  const dataprocClient = new JobControllerClient();

  async function callSubmitJob() {
    // Construct request
    const request = {
      projectId,
      region,
      job,
    };

    // Run request
    const response = await dataprocClient.submitJob(request);
    console.log(response);
  }

  callSubmitJob();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The ID of the Google Cloud Platform project that the job
   *  belongs to.
   */
  // const projectId = 'abc123'
  /**
   *  Required. The Dataproc region in which to handle the request.
   */
  // const region = 'us-central1'
  /**
   *  Required. The job resource.
   */
  // const job = {}
  /**
   *  Optional. A unique id used to identify the request. If the server
   *  receives two
   *  SubmitJobRequest (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#google.cloud.dataproc.v1.SubmitJobRequest)s
   *  with the same id, then the second request will be ignored and the
   *  first Job google.cloud.dataproc.v1.Job  created and stored in the backend
   *  is returned.
   *  It is recommended to always set this value to a
   *  UUID (https://en.wikipedia.org/wiki/Universally_unique_identifier).
   *  The id must contain only letters (a-z, A-Z), numbers (0-9),
   *  underscores (_), and hyphens (-). The maximum length is 40 characters.
   */
  // const requestId = 'abc123'

  // Imports the Dataproc library
  const {JobControllerClient} = require('@google-cloud/dataproc').v1;

  // Instantiates a client
  const dataprocClient = new JobControllerClient();

  async function callSubmitJobAsOperation() {
    // Construct request
    const request = {
      projectId,
      region,
      job,
    };

    // Run request
    const [operation] = await dataprocClient.submitJobAsOperation(request);
    const [response] = await operation.promise();
    console.log(response);
  }

  callSubmitJobAsOperation();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The ID of the Google Cloud Platform project that the job
   *  belongs to.
   */
  // const projectId = 'abc123'
  /**
   *  Required. The Dataproc region in which to handle the request.
   */
  // const region = 'us-central1'
  /**
   *  Required. The job ID.
   */
  // const jobId = 'abc123'
  /**
   *  Required. The changes to the job.
   */
  // const job = {}
  /**
   *  Required. Specifies the path, relative to Job, of
   *  the field to update. For example, to update the labels of a Job the
   *  update_mask parameter would be specified as
   *  labels, and the `PATCH` request body would specify the new
   *  value. Note: Currently, labels is the only
   *  field that can be updated.
   */
  // const updateMask = {}

  // Imports the Dataproc library
  const {JobControllerClient} = require('@google-cloud/dataproc').v1;

  // Instantiates a client
  const dataprocClient = new JobControllerClient();

  async function callUpdateJob() {
    // Construct request
    const request = {
      projectId,
      region,
      jobId,
      job,
      updateMask,
    };

    // Run request
    const response = await dataprocClient.updateJob(request);
    console.log(response);
  }

  callUpdateJob();