Class v1beta3.MetricsV1Beta3Client (2.0.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.
   */
  /**
   *  A project id.
   */
  // const projectId = 'abc123'
  /**
   *  The job to get execution details for.
   */
  // const jobId = 'abc123'
  /**
   *  The regional endpoint 
   *  (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) that
   *  contains the job specified by job_id.
   */
  // const location = 'abc123'
  /**
   *  If specified, determines the maximum number of stages to
   *  return.  If unspecified, the service may choose an appropriate
   *  default, or may return an arbitrarily large number of results.
   */
  // const pageSize = 1234
  /**
   *  If supplied, this should be the value of next_page_token returned
   *  by an earlier call. This will cause the next page of results to
   *  be returned.
   */
  // const pageToken = 'abc123'

  // Imports the Dataflow library
  const {MetricsV1Beta3Client} = require('@google-cloud/dataflow').v1beta3;

  // Instantiates a client
  const dataflowClient = new MetricsV1Beta3Client();

  async function callGetJobExecutionDetails() {
    // Construct request
    const request = {
    };

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

  callGetJobExecutionDetails();

  /**
   * 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.
   */
  /**
   *  A project id.
   */
  // const projectId = 'abc123'
  /**
   *  The job to get metrics for.
   */
  // const jobId = 'abc123'
  /**
   *  Return only metric data that has changed since this time.
   *  Default is to return all information about all metrics for the job.
   */
  // const startTime = {}
  /**
   *  The regional endpoint 
   *  (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) that
   *  contains the job specified by job_id.
   */
  // const location = 'abc123'

  // Imports the Dataflow library
  const {MetricsV1Beta3Client} = require('@google-cloud/dataflow').v1beta3;

  // Instantiates a client
  const dataflowClient = new MetricsV1Beta3Client();

  async function callGetJobMetrics() {
    // Construct request
    const request = {
    };

    // Run request
    const response = await dataflowClient.getJobMetrics(request);
    console.log(response);
  }

  callGetJobMetrics();

  /**
   * 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.
   */
  /**
   *  A project id.
   */
  // const projectId = 'abc123'
  /**
   *  The job to get execution details for.
   */
  // const jobId = 'abc123'
  /**
   *  The regional endpoint 
   *  (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) that
   *  contains the job specified by job_id.
   */
  // const location = 'abc123'
  /**
   *  The stage for which to fetch information.
   */
  // const stageId = 'abc123'
  /**
   *  If specified, determines the maximum number of work items to
   *  return.  If unspecified, the service may choose an appropriate
   *  default, or may return an arbitrarily large number of results.
   */
  // const pageSize = 1234
  /**
   *  If supplied, this should be the value of next_page_token returned
   *  by an earlier call. This will cause the next page of results to
   *  be returned.
   */
  // const pageToken = 'abc123'
  /**
   *  Lower time bound of work items to include, by start time.
   */
  // const startTime = {}
  /**
   *  Upper time bound of work items to include, by start time.
   */
  // const endTime = {}

  // Imports the Dataflow library
  const {MetricsV1Beta3Client} = require('@google-cloud/dataflow').v1beta3;

  // Instantiates a client
  const dataflowClient = new MetricsV1Beta3Client();

  async function callGetStageExecutionDetails() {
    // Construct request
    const request = {
    };

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

  callGetStageExecutionDetails();