Api-roll 46: 2017-03-06

generated/googleapis_beta/lib/dataflow/v1b3.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis_beta.dataflow.v1b3;
 
 import 'dart:core' as core;
 import 'dart:async' as async;
 import 'dart:convert' as convert;
 
 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons;
 import 'package:http/http.dart' as http;
@@ skipping 99 matching lines @@
    *
    * [location] - The location that contains this job.
    *
    * [replaceJobId] - Deprecated. This field is now in the Job message.
    *
    * [view] - The level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
+   * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<Job> create(Job request, core.String projectId, {core.String location, core.String replaceJobId, core.String view}) {
@@ skipping 34 matching lines @@
 
   /**
    * Gets the state of the specified Cloud Dataflow job.
    *
    * Request parameters:
    *
    * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
    * [jobId] - The job ID.
    *
+   * [location] - The location that contains this job.
+   *
    * [view] - The level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
-   *
-   * [location] - The location that contains this job.
+   * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<Job> get(core.String projectId, core.String jobId, {core.String view, core.String location}) {
+  async.Future<Job> get(core.String projectId, core.String jobId, {core.String location, core.String view}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
     if (view != null) {
       _queryParams["view"] = [view];
     }
-    if (location != null) {
-      _queryParams["location"] = [location];
-    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 78 matching lines @@
    * [pageSize] - If there are many jobs, limit response to at most this many.
    * The actual number of jobs returned will be the lesser of max_responses
    * and an unspecified server-defined limit.
    *
    * [view] - Level of information requested in response. Default is
    * `JOB_VIEW_SUMMARY`.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
+   * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
    * Completes with a [ListJobsResponse].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<ListJobsResponse> list(core.String projectId, {core.String filter, core.String location, core.String pageToken, core.int pageSize, core.String view}) {
@@ skipping 207 matching lines @@
 
   /**
    * Request the job status.
    *
    * Request parameters:
    *
    * [projectId] - A project id.
    *
    * [jobId] - The job to get messages about.
    *
+   * [startTime] - If specified, return only messages with timestamps >=
+   * start_time.
+   * The default is the job creation time (i.e. beginning of messages).
+   *
+   * [pageToken] - 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.
+   *
+   * [pageSize] - If specified, determines the maximum number of messages to
+   * return.  If unspecified, the service may choose an appropriate
+   * default, or may return an arbitrarily large number of results.
+   *
    * [minimumImportance] - Filter to only get messages with importance >= level
    * Possible string values are:
    * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN.
    * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG.
    * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED.
    * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC.
    * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING.
    * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR.
    *
    * [location] - The location which contains the job specified by job_id.
    *
    * [endTime] - Return only messages with timestamps < end_time. The default is
    * now
    * (i.e. return up to the latest messages available).
    *
-   * [startTime] - If specified, return only messages with timestamps >=
-   * start_time.
-   * The default is the job creation time (i.e. beginning of messages).
-   *
-   * [pageToken] - 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.
-   *
-   * [pageSize] - If specified, determines the maximum number of messages to
-   * return.  If unspecified, the service may choose an appropriate
-   * default, or may return an arbitrarily large number of results.
-   *
    * Completes with a [ListJobMessagesResponse].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.String minimumImportance, core.String location, core.String endTime, core.String startTime, core.String pageToken, core.int pageSize}) {
+  async.Future<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.String startTime, core.String pageToken, core.int pageSize, core.String minimumImportance, core.String location, core.String endTime}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
-    if (minimumImportance != null) {
-      _queryParams["minimumImportance"] = [minimumImportance];
-    }
-    if (location != null) {
-      _queryParams["location"] = [location];
-    }
-    if (endTime != null) {
-      _queryParams["endTime"] = [endTime];
-    }
     if (startTime != null) {
       _queryParams["startTime"] = [startTime];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
+    if (minimumImportance != null) {
+      _queryParams["minimumImportance"] = [minimumImportance];
+    }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
+    if (endTime != null) {
+      _queryParams["endTime"] = [endTime];
+    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 133 matching lines @@
    * Creates a Cloud Dataflow job.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
    * [location] - The location that contains this job.
    *
+   * [replaceJobId] - Deprecated. This field is now in the Job message.
+   *
    * [view] - The level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
-   *
-   * [replaceJobId] - Deprecated. This field is now in the Job message.
+   * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<Job> create(Job request, core.String projectId, core.String location, {core.String view, core.String replaceJobId}) {
+  async.Future<Job> create(Job request, core.String projectId, core.String location, {core.String replaceJobId, core.String view}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (location == null) {
       throw new core.ArgumentError("Parameter location is required.");
     }
+    if (replaceJobId != null) {
+      _queryParams["replaceJobId"] = [replaceJobId];
+    }
     if (view != null) {
       _queryParams["view"] = [view];
     }
-    if (replaceJobId != null) {
-      _queryParams["replaceJobId"] = [replaceJobId];
-    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
   /**
    * Gets the state of the specified Cloud Dataflow job.
    *
    * Request parameters:
    *
    * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
    * [location] - The location that contains this job.
    *
    * [jobId] - The job ID.
    *
    * [view] - The level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
+   * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<Job> get(core.String projectId, core.String location, core.String jobId, {core.String view}) {
@@ skipping 107 matching lines @@
    * [pageSize] - If there are many jobs, limit response to at most this many.
    * The actual number of jobs returned will be the lesser of max_responses
    * and an unspecified server-defined limit.
    *
    * [view] - Level of information requested in response. Default is
    * `JOB_VIEW_SUMMARY`.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
+   * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
    * Completes with a [ListJobsResponse].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<ListJobsResponse> list(core.String projectId, core.String location, {core.String filter, core.String pageToken, core.int pageSize, core.String view}) {
@@ skipping 106 matching lines @@
    * [projectId] - A project id.
    *
    * [location] - The location which contains the job specified by job_id.
    *
    * [jobId] - The job to get messages about.
    *
    * [endTime] - Return only messages with timestamps < end_time. The default is
    * now
    * (i.e. return up to the latest messages available).
    *
-   * [startTime] - If specified, return only messages with timestamps >=
-   * start_time.
-   * The default is the job creation time (i.e. beginning of messages).
-   *
    * [pageToken] - 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.
    *
+   * [startTime] - If specified, return only messages with timestamps >=
+   * start_time.
+   * The default is the job creation time (i.e. beginning of messages).
+   *
    * [pageSize] - If specified, determines the maximum number of messages to
    * return.  If unspecified, the service may choose an appropriate
    * default, or may return an arbitrarily large number of results.
    *
    * [minimumImportance] - Filter to only get messages with importance >= level
    * Possible string values are:
    * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN.
    * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG.
    * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED.
    * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC.
    * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING.
    * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR.
    *
    * Completes with a [ListJobMessagesResponse].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<ListJobMessagesResponse> list(core.String projectId, core.String location, core.String jobId, {core.String endTime, core.String startTime, core.String pageToken, core.int pageSize, core.String minimumImportance}) {
+  async.Future<ListJobMessagesResponse> list(core.String projectId, core.String location, core.String jobId, {core.String endTime, core.String pageToken, core.String startTime, core.int pageSize, core.String minimumImportance}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (location == null) {
       throw new core.ArgumentError("Parameter location is required.");
     }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
     if (endTime != null) {
       _queryParams["endTime"] = [endTime];
     }
+    if (pageToken != null) {
+      _queryParams["pageToken"] = [pageToken];
+    }
     if (startTime != null) {
       _queryParams["startTime"] = [startTime];
     }
-    if (pageToken != null) {
-      _queryParams["pageToken"] = [pageToken];
-    }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (minimumImportance != null) {
       _queryParams["minimumImportance"] = [minimumImportance];
     }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
 
     var _response = _requester.request(_url,
@@ skipping 170 matching lines @@
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
+  /**
+   * Get the template associated with a template.
+   *
+   * Request parameters:
+   *
+   * [projectId] - Required. The ID of the Cloud Platform project that the job
+   * belongs to.
+   *
+   * [view] - The view to retrieve. Defaults to METADATA_ONLY.
+   * Possible string values are:
+   * - "METADATA_ONLY" : A METADATA_ONLY.
+   *
+   * [gcsPath] - Required. A Cloud Storage path to the template from which to
+   * create the job.
+   * Must be a valid Cloud Storage URL, beginning with `gs://`.
+   *
+   * Completes with a [GetTemplateResponse].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<GetTemplateResponse> get(core.String projectId, {core.String view, core.String gcsPath}) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (view != null) {
+      _queryParams["view"] = [view];
+    }
+    if (gcsPath != null) {
+      _queryParams["gcsPath"] = [gcsPath];
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/templates:get';
+
+    var _response = _requester.request(_url,
+                                       "GET",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new GetTemplateResponse.fromJson(data));
+  }
+
+  /**
+   * Launch a template.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - Required. The ID of the Cloud Platform project that the job
+   * belongs to.
+   *
+   * [dryRun] - Whether or not the job should actually be executed after
+   * validating parameters. Defaults to false. Validation errors do
+   * not cause the HTTP request to fail if true.
+   *
+   * [gcsPath] - Required. A Cloud Storage path to the template from which to
+   * create
+   * the job.
+   * Must be valid Cloud Storage URL, beginning with 'gs://'.
+   *
+   * Completes with a [LaunchTemplateResponse].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request, core.String projectId, {core.bool dryRun, core.String gcsPath}) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (dryRun != null) {
+      _queryParams["dryRun"] = ["${dryRun}"];
+    }
+    if (gcsPath != null) {
+      _queryParams["gcsPath"] = [gcsPath];
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/templates:launch';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new LaunchTemplateResponse.fromJson(data));
+  }
+
 }
 
 
 
 /**
  * Obsolete in favor of ApproximateReportedProgress and ApproximateSplitRequest.
  */
 class ApproximateProgress {
   /** Obsolete. */
   core.double percentComplete;
@@ skipping 223 matching lines @@
     if (timestamp != null) {
       _json["timestamp"] = timestamp;
     }
     if (totalMs != null) {
       _json["totalMs"] = totalMs;
     }
     return _json;
   }
 }
 
+/**
+ * Description of an interstitial value between transforms in an execution
+ * stage.
+ */
+class ComponentSource {
+  /** Dataflow service generated name for this source. */
+  core.String name;
+  /**
+   * User name for the original user transform or collection with which this
+   * source is most closely associated.
+   */
+  core.String originalTransformOrCollection;
+  /**
+   * Human-readable name for this transform; may be user or system generated.
+   */
+  core.String userName;
+
+  ComponentSource();
+
+  ComponentSource.fromJson(core.Map _json) {
+    if (_json.containsKey("name")) {
+      name = _json["name"];
+    }
+    if (_json.containsKey("originalTransformOrCollection")) {
+      originalTransformOrCollection = _json["originalTransformOrCollection"];
+    }
+    if (_json.containsKey("userName")) {
+      userName = _json["userName"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (name != null) {
+      _json["name"] = name;
+    }
+    if (originalTransformOrCollection != null) {
+      _json["originalTransformOrCollection"] = originalTransformOrCollection;
+    }
+    if (userName != null) {
+      _json["userName"] = userName;
+    }
+    return _json;
+  }
+}
+
+/** Description of a transform executed as part of an execution stage. */
+class ComponentTransform {
+  /** Dataflow service generated name for this source. */
+  core.String name;
+  /**
+   * User name for the original user transform with which this transform is
+   * most closely associated.
+   */
+  core.String originalTransform;
+  /**
+   * Human-readable name for this transform; may be user or system generated.
+   */
+  core.String userName;
+
+  ComponentTransform();
+
+  ComponentTransform.fromJson(core.Map _json) {
+    if (_json.containsKey("name")) {
+      name = _json["name"];
+    }
+    if (_json.containsKey("originalTransform")) {
+      originalTransform = _json["originalTransform"];
+    }
+    if (_json.containsKey("userName")) {
+      userName = _json["userName"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (name != null) {
+      _json["name"] = name;
+    }
+    if (originalTransform != null) {
+      _json["originalTransform"] = originalTransform;
+    }
+    if (userName != null) {
+      _json["userName"] = userName;
+    }
+    return _json;
+  }
+}
+
 /** All configuration data for a particular Computation. */
 class ComputationTopology {
   /** The ID of the computation. */
   core.String computationId;
   /** The inputs to the computation. */
   core.List<StreamLocation> inputs;
   /** The key ranges processed by the computation. */
   core.List<KeyRangeLocation> keyRanges;
   /** The outputs from the computation. */
   core.List<StreamLocation> outputs;
@@ skipping 648 matching lines @@
     if (mountPoint != null) {
       _json["mountPoint"] = mountPoint;
     }
     if (sizeGb != null) {
       _json["sizeGb"] = sizeGb;
     }
     return _json;
   }
 }
 
+/** Data provided with a pipeline or transform to provide descriptive info. */
+class DisplayData {
+  /** Contains value if the data is of a boolean type. */
+  core.bool boolValue;
+  /** Contains value if the data is of duration type. */
+  core.String durationValue;
+  /** Contains value if the data is of float type. */
+  core.double floatValue;
+  /** Contains value if the data is of int64 type. */
+  core.String int64Value;
+  /** Contains value if the data is of java class type. */
+  core.String javaClassValue;
+  /**
+   * The key identifying the display data.
+   * This is intended to be used as a label for the display data
+   * when viewed in a dax monitoring system.
+   */
+  core.String key;
+  /** An optional label to display in a dax UI for the element. */
+  core.String label;
+  /**
+   * The namespace for the key. This is usually a class name or programming
+   * language namespace (i.e. python module) which defines the display data.
+   * This allows a dax monitoring system to specially handle the data
+   * and perform custom rendering.
+   */
+  core.String namespace;
+  /**
+   * A possible additional shorter value to display.
+   * For example a java_class_name_value of com.mypackage.MyDoFn
+   * will be stored with MyDoFn as the short_str_value and
+   * com.mypackage.MyDoFn as the java_class_name value.
+   * short_str_value can be displayed and java_class_name_value
+   * will be displayed as a tooltip.
+   */
+  core.String shortStrValue;
+  /** Contains value if the data is of string type. */
+  core.String strValue;
+  /** Contains value if the data is of timestamp type. */
+  core.String timestampValue;
+  /** An optional full URL. */
+  core.String url;
+
+  DisplayData();
+
+  DisplayData.fromJson(core.Map _json) {
+    if (_json.containsKey("boolValue")) {
+      boolValue = _json["boolValue"];
+    }
+    if (_json.containsKey("durationValue")) {
+      durationValue = _json["durationValue"];
+    }
+    if (_json.containsKey("floatValue")) {
+      floatValue = _json["floatValue"];
+    }
+    if (_json.containsKey("int64Value")) {
+      int64Value = _json["int64Value"];
+    }
+    if (_json.containsKey("javaClassValue")) {
+      javaClassValue = _json["javaClassValue"];
+    }
+    if (_json.containsKey("key")) {
+      key = _json["key"];
+    }
+    if (_json.containsKey("label")) {
+      label = _json["label"];
+    }
+    if (_json.containsKey("namespace")) {
+      namespace = _json["namespace"];
+    }
+    if (_json.containsKey("shortStrValue")) {
+      shortStrValue = _json["shortStrValue"];
+    }
+    if (_json.containsKey("strValue")) {
+      strValue = _json["strValue"];
+    }
+    if (_json.containsKey("timestampValue")) {
+      timestampValue = _json["timestampValue"];
+    }
+    if (_json.containsKey("url")) {
+      url = _json["url"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (boolValue != null) {
+      _json["boolValue"] = boolValue;
+    }
+    if (durationValue != null) {
+      _json["durationValue"] = durationValue;
+    }
+    if (floatValue != null) {
+      _json["floatValue"] = floatValue;
+    }
+    if (int64Value != null) {
+      _json["int64Value"] = int64Value;
+    }
+    if (javaClassValue != null) {
+      _json["javaClassValue"] = javaClassValue;
+    }
+    if (key != null) {
+      _json["key"] = key;
+    }
+    if (label != null) {
+      _json["label"] = label;
+    }
+    if (namespace != null) {
+      _json["namespace"] = namespace;
+    }
+    if (shortStrValue != null) {
+      _json["shortStrValue"] = shortStrValue;
+    }
+    if (strValue != null) {
+      _json["strValue"] = strValue;
+    }
+    if (timestampValue != null) {
+      _json["timestampValue"] = timestampValue;
+    }
+    if (url != null) {
+      _json["url"] = url;
+    }
+    return _json;
+  }
+}
+
 /** A metric value representing a distribution. */
 class DistributionUpdate {
   /** The count of the number of elements present in the distribution. */
   SplitInt64 count;
   /** The maximum value present in the distribution. */
   SplitInt64 max;
   /** The minimum value present in the distribution. */
   SplitInt64 min;
   /**
    * Use an int64 since we'd prefer the added precision. If overflow is a common
@@ skipping 224 matching lines @@
       _json["userAgent"] = userAgent;
     }
     if (version != null) {
       _json["version"] = version;
     }
     if (workerPools != null) {
       _json["workerPools"] = workerPools.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
+}
+
+/**
+ * Description of the composing transforms, names/ids, and input/outputs of a
+ * stage of execution.  Some composing transforms and sources may have been
+ * generated by the Dataflow service during execution planning.
+ */
+class ExecutionStageSummary {
+  /**
+   * Collections produced and consumed by component transforms of this stage.
+   */
+  core.List<ComponentSource> componentSource;
+  /** Transforms that comprise this execution stage. */
+  core.List<ComponentTransform> componentTransform;
+  /** Dataflow service generated id for this stage. */
+  core.String id;
+  /** Input sources for this stage. */
+  core.List<StageSource> inputSource;
+  /**
+   * Type of tranform this stage is executing.
+   * Possible string values are:
+   * - "UNKNOWN_KIND" : Unrecognized transform type.
+   * - "PAR_DO_KIND" : ParDo transform.
+   * - "GROUP_BY_KEY_KIND" : Group By Key transform.
+   * - "FLATTEN_KIND" : Flatten transform.
+   * - "READ_KIND" : Read transform.
+   * - "WRITE_KIND" : Write transform.
+   * - "CONSTANT_KIND" : Constructs from a constant value, such as with
+   * Create.of.
+   * - "SINGLETON_KIND" : Creates a Singleton view of a collection.
+   * - "SHUFFLE_KIND" : Opening or closing a shuffle session, often as part of a
+   * GroupByKey.
+   */
+  core.String kind;
+  /** Dataflow service generated name for this stage. */
+  core.String name;
+  /** Output sources for this stage. */
+  core.List<StageSource> outputSource;
+
+  ExecutionStageSummary();
+
+  ExecutionStageSummary.fromJson(core.Map _json) {
+    if (_json.containsKey("componentSource")) {
+      componentSource = _json["componentSource"].map((value) => new ComponentSource.fromJson(value)).toList();
+    }
+    if (_json.containsKey("componentTransform")) {
+      componentTransform = _json["componentTransform"].map((value) => new ComponentTransform.fromJson(value)).toList();
+    }
+    if (_json.containsKey("id")) {
+      id = _json["id"];
+    }
+    if (_json.containsKey("inputSource")) {
+      inputSource = _json["inputSource"].map((value) => new StageSource.fromJson(value)).toList();
+    }
+    if (_json.containsKey("kind")) {
+      kind = _json["kind"];
+    }
+    if (_json.containsKey("name")) {
+      name = _json["name"];
+    }
+    if (_json.containsKey("outputSource")) {
+      outputSource = _json["outputSource"].map((value) => new StageSource.fromJson(value)).toList();
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (componentSource != null) {
+      _json["componentSource"] = componentSource.map((value) => (value).toJson()).toList();
+    }
+    if (componentTransform != null) {
+      _json["componentTransform"] = componentTransform.map((value) => (value).toJson()).toList();
+    }
+    if (id != null) {
+      _json["id"] = id;
+    }
+    if (inputSource != null) {
+      _json["inputSource"] = inputSource.map((value) => (value).toJson()).toList();
+    }
+    if (kind != null) {
+      _json["kind"] = kind;
+    }
+    if (name != null) {
+      _json["name"] = name;
+    }
+    if (outputSource != null) {
+      _json["outputSource"] = outputSource.map((value) => (value).toJson()).toList();
+    }
+    return _json;
+  }
 }
 
 /** Indicates which location failed to respond to a request for data. */
 class FailedLocation {
   /** The name of the failed location. */
   core.String name;
 
   FailedLocation();
 
   FailedLocation.fromJson(core.Map _json) {
@@ skipping 135 matching lines @@
 
   core.Map toJson() {
     var _json = new core.Map();
     if (config != null) {
       _json["config"] = config;
     }
     return _json;
   }
 }
 
+/** The response to a GetTemplate request. */
+class GetTemplateResponse {
+  /**
+   * The template metadata describing the template name, available
+   * parameters, etc.
+   */
+  TemplateMetadata metadata;
+  /**
+   * The status of the get template request. Any problems with the
+   * request will be indicated in the error_details.
+   */
+  Status status;
+
+  GetTemplateResponse();
+
+  GetTemplateResponse.fromJson(core.Map _json) {
+    if (_json.containsKey("metadata")) {
+      metadata = new TemplateMetadata.fromJson(_json["metadata"]);
+    }
+    if (_json.containsKey("status")) {
+      status = new Status.fromJson(_json["status"]);
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (metadata != null) {
+      _json["metadata"] = (metadata).toJson();
+    }
+    if (status != null) {
+      _json["status"] = (status).toJson();
+    }
+    return _json;
+  }
+}
+
 /**
  * An input of an instruction, as a reference to an output of a
  * producer instruction.
  */
 class InstructionInput {
   /** The output index (origin zero) within the producer. */
   core.int outputNum;
   /**
    * The index (origin zero) of the parallel instruction that produces
    * the output to be consumed by this input.  This index is relative
@@ skipping 224 matching lines @@
    * A drained job terminated by stopping pulling from its input sources and
    * processing any data that remained in-flight when draining was requested.
    * This state is a terminal state, may only be set by the Cloud Dataflow
    * service, and only as a transition from `JOB_STATE_DRAINING`.
    */
   core.String currentState;
   /** The timestamp associated with the current state. */
   core.String currentStateTime;
   /** The environment for the job. */
   Environment environment;
-  /** Information about how the Cloud Dataflow service will run the job. */
+  /** Deprecated. */
   JobExecutionInfo executionInfo;
   /**
    * The unique ID of this job.
    *
    * This field is set by the Cloud Dataflow service when the Job is
    * created, and is immutable for the life of the job.
    */
   core.String id;
   /**
    * User-defined labels for this job.
@@ skipping 14 matching lines @@
    *
    * Only one Job with a given name may exist in a project at any
    * given time. If a caller attempts to create a Job with the same
    * name as an already-existing Job, the attempt returns the
    * existing Job.
    *
    * The name must match the regular expression
    * `[a-z]([-a-z0-9]{0,38}[a-z0-9])?`
    */
   core.String name;
+  /**
+   * Preliminary field: The format of this data may change at any time.
+   * A description of the user pipeline and stages through which it is executed.
+   * Created by Cloud Dataflow service.  Only retrieved with
+   * JOB_VIEW_DESCRIPTION or JOB_VIEW_ALL.
+   */
+  PipelineDescription pipelineDescription;
   /** The ID of the Cloud Platform project that the job belongs to. */
   core.String projectId;
   /**
    * If this job is an update of an existing job, this field is the job ID
    * of the job it replaced.
    *
    * When sending a `CreateJobRequest`, you can update a job by specifying it
    * here. The job named here is stopped, and its intermediate state is
    * transferred to this job.
    */
@@ skipping 114 matching lines @@
     }
     if (_json.containsKey("labels")) {
       labels = _json["labels"];
     }
     if (_json.containsKey("location")) {
       location = _json["location"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
+    if (_json.containsKey("pipelineDescription")) {
+      pipelineDescription = new PipelineDescription.fromJson(_json["pipelineDescription"]);
+    }
     if (_json.containsKey("projectId")) {
       projectId = _json["projectId"];
     }
     if (_json.containsKey("replaceJobId")) {
       replaceJobId = _json["replaceJobId"];
     }
     if (_json.containsKey("replacedByJobId")) {
       replacedByJobId = _json["replacedByJobId"];
     }
     if (_json.containsKey("requestedState")) {
@@ skipping 38 matching lines @@
     }
     if (labels != null) {
       _json["labels"] = labels;
     }
     if (location != null) {
       _json["location"] = location;
     }
     if (name != null) {
       _json["name"] = name;
     }
+    if (pipelineDescription != null) {
+      _json["pipelineDescription"] = (pipelineDescription).toJson();
+    }
     if (projectId != null) {
       _json["projectId"] = projectId;
     }
     if (replaceJobId != null) {
       _json["replaceJobId"] = replaceJobId;
     }
     if (replacedByJobId != null) {
       _json["replacedByJobId"] = replacedByJobId;
     }
     if (requestedState != null) {
@@ skipping 299 matching lines @@
     if (persistentDirectory != null) {
       _json["persistentDirectory"] = persistentDirectory;
     }
     if (start != null) {
       _json["start"] = start;
     }
     return _json;
   }
 }
 
+/** Parameters to provide to the template being launched. */
+class LaunchTemplateParameters {
+  /** The runtime environment for the job. */
+  RuntimeEnvironment environment;
+  /** Required. The job name to use for the created job. */
+  core.String jobName;
+  /** The runtime parameters to pass to the job. */
+  core.Map<core.String, core.String> parameters;
+
+  LaunchTemplateParameters();
+
+  LaunchTemplateParameters.fromJson(core.Map _json) {
+    if (_json.containsKey("environment")) {
+      environment = new RuntimeEnvironment.fromJson(_json["environment"]);
+    }
+    if (_json.containsKey("jobName")) {
+      jobName = _json["jobName"];
+    }
+    if (_json.containsKey("parameters")) {
+      parameters = _json["parameters"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (environment != null) {
+      _json["environment"] = (environment).toJson();
+    }
+    if (jobName != null) {
+      _json["jobName"] = jobName;
+    }
+    if (parameters != null) {
+      _json["parameters"] = parameters;
+    }
+    return _json;
+  }
+}
+
+/** Response to the request to launch a template. */
+class LaunchTemplateResponse {
+  /**
+   * The job that was launched, if the request was not a dry run and
+   * the job was successfully launched.
+   */
+  Job job;
+  /**
+   * The status of the launch template request. Any problems with the request
+   * will be indicated in the error_details.
+   */
+  Status status;
+
+  LaunchTemplateResponse();
+
+  LaunchTemplateResponse.fromJson(core.Map _json) {
+    if (_json.containsKey("job")) {
+      job = new Job.fromJson(_json["job"]);
+    }
+    if (_json.containsKey("status")) {
+      status = new Status.fromJson(_json["status"]);
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (job != null) {
+      _json["job"] = (job).toJson();
+    }
+    if (status != null) {
+      _json["status"] = (status).toJson();
+    }
+    return _json;
+  }
+}
+
 /** Request to lease WorkItems. */
 class LeaseWorkItemRequest {
   /** The current timestamp at the worker. */
   core.String currentWorkerTime;
   /** The location which contains the WorkItem's job. */
   core.String location;
   /** The initial lease period. */
   core.String requestedLeaseDuration;
   /** Filter for WorkItem type. */
   core.List<core.String> workItemTypes;
@@ skipping 714 matching lines @@
     if (systemName != null) {
       _json["systemName"] = systemName;
     }
     if (write != null) {
       _json["write"] = (write).toJson();
     }
     return _json;
   }
 }
 
+/** Metadata for a specific parameter. */
+class ParameterMetadata {
+  /** Required. The help text to display for the parameter. */
+  core.String helpText;
+  /** Optional. Whether the parameter is optional. Defaults to false. */
+  core.bool isOptional;
+  /** Required. The label to display for the parameter. */
+  core.String label;
+  /** Required. The name of the parameter. */
+  core.String name;
+  /** Optional. Regexes that the parameter must match. */
+  core.List<core.String> regexes;
+
+  ParameterMetadata();
+
+  ParameterMetadata.fromJson(core.Map _json) {
+    if (_json.containsKey("helpText")) {
+      helpText = _json["helpText"];
+    }
+    if (_json.containsKey("isOptional")) {
+      isOptional = _json["isOptional"];
+    }
+    if (_json.containsKey("label")) {
+      label = _json["label"];
+    }
+    if (_json.containsKey("name")) {
+      name = _json["name"];
+    }
+    if (_json.containsKey("regexes")) {
+      regexes = _json["regexes"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (helpText != null) {
+      _json["helpText"] = helpText;
+    }
+    if (isOptional != null) {
+      _json["isOptional"] = isOptional;
+    }
+    if (label != null) {
+      _json["label"] = label;
+    }
+    if (name != null) {
+      _json["name"] = name;
+    }
+    if (regexes != null) {
+      _json["regexes"] = regexes;
+    }
+    return _json;
+  }
+}
+
 /**
  * An instruction that does a partial group-by-key.
  * One input and one output.
  */
 class PartialGroupByKeyInstruction {
   /** Describes the input to the partial group-by-key instruction. */
   InstructionInput input;
   /**
    * The codec to use for interpreting an element in the input PTable.
    *
@@ skipping 62 matching lines @@
       _json["sideInputs"] = sideInputs.map((value) => (value).toJson()).toList();
     }
     if (valueCombiningFn != null) {
       _json["valueCombiningFn"] = valueCombiningFn;
     }
     return _json;
   }
 }
 
 /**
+ * A descriptive representation of submitted pipeline as well as the executed
+ * form.  This data is provided by the Dataflow service for ease of visualizing
+ * the pipeline and interpretting Dataflow provided metrics.
+ */
+class PipelineDescription {
+  /** Pipeline level display data. */
+  core.List<DisplayData> displayData;
+  /** Description of each stage of execution of the pipeline. */
+  core.List<ExecutionStageSummary> executionPipelineStage;
+  /**
+   * Description of each transform in the pipeline and collections between them.
+   */
+  core.List<TransformSummary> originalPipelineTransform;
+
+  PipelineDescription();
+
+  PipelineDescription.fromJson(core.Map _json) {
+    if (_json.containsKey("displayData")) {
+      displayData = _json["displayData"].map((value) => new DisplayData.fromJson(value)).toList();
+    }
+    if (_json.containsKey("executionPipelineStage")) {
+      executionPipelineStage = _json["executionPipelineStage"].map((value) => new ExecutionStageSummary.fromJson(value)).toList();
+    }
+    if (_json.containsKey("originalPipelineTransform")) {
+      originalPipelineTransform = _json["originalPipelineTransform"].map((value) => new TransformSummary.fromJson(value)).toList();
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (displayData != null) {
+      _json["displayData"] = displayData.map((value) => (value).toJson()).toList();
+    }
+    if (executionPipelineStage != null) {
+      _json["executionPipelineStage"] = executionPipelineStage.map((value) => (value).toJson()).toList();
+    }
+    if (originalPipelineTransform != null) {
+      _json["originalPipelineTransform"] = originalPipelineTransform.map((value) => (value).toJson()).toList();
+    }
+    return _json;
+  }
+}
+
+/**
  * Position defines a position within a collection of data.  The value
  * can be either the end position, a key (used with ordered
  * collections), a byte offset, or a record index.
  */
 class Position {
   /** Position is a byte offset. */
   core.String byteOffset;
   /** CloudPosition is a concat position. */
   ConcatPosition concatPosition;
   /**
@@ skipping 1236 matching lines @@
     if (highBits != null) {
       _json["highBits"] = highBits;
     }
     if (lowBits != null) {
       _json["lowBits"] = lowBits;
     }
     return _json;
   }
 }
 
+/** Description of an input or output of an execution stage. */
+class StageSource {
+  /** Dataflow service generated name for this source. */
+  core.String name;
+  /**
+   * User name for the original user transform or collection with which this
+   * source is most closely associated.
+   */
+  core.String originalTransformOrCollection;
+  /** Size of the source, if measurable. */
+  core.String sizeBytes;
+  /** Human-readable name for this source; may be user or system generated. */
+  core.String userName;
+
+  StageSource();
+
+  StageSource.fromJson(core.Map _json) {
+    if (_json.containsKey("name")) {
+      name = _json["name"];
+    }
+    if (_json.containsKey("originalTransformOrCollection")) {
+      originalTransformOrCollection = _json["originalTransformOrCollection"];
+    }
+    if (_json.containsKey("sizeBytes")) {
+      sizeBytes = _json["sizeBytes"];
+    }
+    if (_json.containsKey("userName")) {
+      userName = _json["userName"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (name != null) {
+      _json["name"] = name;
+    }
+    if (originalTransformOrCollection != null) {
+      _json["originalTransformOrCollection"] = originalTransformOrCollection;
+    }
+    if (sizeBytes != null) {
+      _json["sizeBytes"] = sizeBytes;
+    }
+    if (userName != null) {
+      _json["userName"] = userName;
+    }
+    return _json;
+  }
+}
+
 /** State family configuration. */
 class StateFamilyConfig {
   /** If true, this family corresponds to a read operation. */
   core.bool isRead;
   /** The state family value. */
   core.String stateFamily;
 
   StateFamilyConfig();
 
   StateFamilyConfig.fromJson(core.Map _json) {
@@ skipping 151 matching lines @@
   /** The kind of step in the Cloud Dataflow job. */
   core.String kind;
   /**
    * The name that identifies the step. This must be unique for each
    * step with respect to all other steps in the Cloud Dataflow job.
    */
   core.String name;
   /**
    * Named properties associated with the step. Each kind of
    * predefined step has its own required set of properties.
+   * Must be provided on Create.  Only retrieved with JOB_VIEW_ALL.
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> properties;
 
   Step();
 
   Step.fromJson(core.Map _json) {
     if (_json.containsKey("kind")) {
@@ skipping 568 matching lines @@
     if (vmId != null) {
       _json["vmId"] = vmId;
     }
     if (workflowFileName != null) {
       _json["workflowFileName"] = workflowFileName;
     }
     return _json;
   }
 }
 
+/** Metadata describing a template. */
+class TemplateMetadata {
+  /**
+   * If true, will bypass the validation that the temp directory is
+   * writable. This should only be used with templates for pipelines
+   * that are guaranteed not to need to write to the temp directory,
+   * which is subject to change based on the optimizer.
+   */
+  core.bool bypassTempDirValidation;
+  /** Optional. A description of the template. */
+  core.String description;
+  /** Required. The name of the template. */
+  core.String name;
+  /** The parameters for the template. */
+  core.List<ParameterMetadata> parameters;
+
+  TemplateMetadata();
+
+  TemplateMetadata.fromJson(core.Map _json) {
+    if (_json.containsKey("bypassTempDirValidation")) {
+      bypassTempDirValidation = _json["bypassTempDirValidation"];
+    }
+    if (_json.containsKey("description")) {
+      description = _json["description"];
+    }
+    if (_json.containsKey("name")) {
+      name = _json["name"];
+    }
+    if (_json.containsKey("parameters")) {
+      parameters = _json["parameters"].map((value) => new ParameterMetadata.fromJson(value)).toList();
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (bypassTempDirValidation != null) {
+      _json["bypassTempDirValidation"] = bypassTempDirValidation;
+    }
+    if (description != null) {
+      _json["description"] = description;
+    }
+    if (name != null) {
+      _json["name"] = name;
+    }
+    if (parameters != null) {
+      _json["parameters"] = parameters.map((value) => (value).toJson()).toList();
+    }
+    return _json;
+  }
+}
+
 /**
  * Global topology of the streaming Dataflow job, including all
  * computations and their sharded locations.
  */
 class TopologyConfig {
   /** The computations associated with a streaming Dataflow job. */
   core.List<ComputationTopology> computations;
   /** The disks assigned to a streaming Dataflow job. */
   core.List<DataDiskAssignment> dataDiskAssignments;
   /** The size (in bits) of keys that will be assigned to source messages. */
@@ skipping 37 matching lines @@
     if (persistentStateVersion != null) {
       _json["persistentStateVersion"] = persistentStateVersion;
     }
     if (userStageToComputationNameMap != null) {
       _json["userStageToComputationNameMap"] = userStageToComputationNameMap;
     }
     return _json;
   }
 }
 
+/** Description of the type, names/ids, and input/outputs for a transform. */
+class TransformSummary {
+  /** Transform-specific display data. */
+  core.List<DisplayData> displayData;
+  /** SDK generated id of this transform instance. */
+  core.String id;
+  /** User names for all collection inputs to this transform. */
+  core.List<core.String> inputCollectionName;
+  /**
+   * Type of transform.
+   * Possible string values are:
+   * - "UNKNOWN_KIND" : Unrecognized transform type.
+   * - "PAR_DO_KIND" : ParDo transform.
+   * - "GROUP_BY_KEY_KIND" : Group By Key transform.
+   * - "FLATTEN_KIND" : Flatten transform.
+   * - "READ_KIND" : Read transform.
+   * - "WRITE_KIND" : Write transform.
+   * - "CONSTANT_KIND" : Constructs from a constant value, such as with
+   * Create.of.
+   * - "SINGLETON_KIND" : Creates a Singleton view of a collection.
+   * - "SHUFFLE_KIND" : Opening or closing a shuffle session, often as part of a
+   * GroupByKey.
+   */
+  core.String kind;
+  /** User provided name for this transform instance. */
+  core.String name;
+  /** User  names for all collection outputs to this transform. */
+  core.List<core.String> outputCollectionName;
+
+  TransformSummary();
+
+  TransformSummary.fromJson(core.Map _json) {
+    if (_json.containsKey("displayData")) {
+      displayData = _json["displayData"].map((value) => new DisplayData.fromJson(value)).toList();
+    }
+    if (_json.containsKey("id")) {
+      id = _json["id"];
+    }
+    if (_json.containsKey("inputCollectionName")) {
+      inputCollectionName = _json["inputCollectionName"];
+    }
+    if (_json.containsKey("kind")) {
+      kind = _json["kind"];
+    }
+    if (_json.containsKey("name")) {
+      name = _json["name"];
+    }
+    if (_json.containsKey("outputCollectionName")) {
+      outputCollectionName = _json["outputCollectionName"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (displayData != null) {
+      _json["displayData"] = displayData.map((value) => (value).toJson()).toList();
+    }
+    if (id != null) {
+      _json["id"] = id;
+    }
+    if (inputCollectionName != null) {
+      _json["inputCollectionName"] = inputCollectionName;
+    }
+    if (kind != null) {
+      _json["kind"] = kind;
+    }
+    if (name != null) {
+      _json["name"] = name;
+    }
+    if (outputCollectionName != null) {
+      _json["outputCollectionName"] = outputCollectionName;
+    }
+    return _json;
+  }
+}
+
 /**
  * WorkItem represents basic information about a WorkItem to be executed
  * in the cloud.
  */
 class WorkItem {
   /** Work item-specific configuration as an opaque blob. */
   core.String configuration;
   /** Identifies this WorkItem. */
   core.String id;
   /** The initial index to use when reporting the status of the WorkItem. */
@@ skipping 1057 matching lines @@
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }