Api-Roll 50: 2017-06-12

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;
 
 export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show
     ApiRequestError, DetailedApiRequestError;
 
 const core.String USER_AGENT = 'dart-api-client dataflow/v1b3';
 
 /** Manages Google Cloud Dataflow projects on Google Cloud Platform. */
 class DataflowApi {
   /** View and manage your data across Google Cloud Platform services */
   static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform";
 
   /** View and manage your Google Compute Engine resources */
   static const ComputeScope = "https://www.googleapis.com/auth/compute";
 
+  /** View your Google Compute Engine resources */
+  static const ComputeReadonlyScope = "https://www.googleapis.com/auth/compute.readonly";
+
   /** View your email address */
   static const UserinfoEmailScope = "https://www.googleapis.com/auth/userinfo.email";
 
 
   final commons.ApiRequester _requester;
 
   ProjectsResourceApi get projects => new ProjectsResourceApi(_requester);
 
   DataflowApi(http.Client client, {core.String rootUrl: "https://dataflow.googleapis.com/", core.String servicePath: ""}) :
       _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT);
@@ skipping 192 matching lines @@
 
   /**
    * Request the job status.
    *
    * Request parameters:
    *
    * [projectId] - A project id.
    *
    * [jobId] - The job to get messages for.
    *
-   * [location] - The location which contains the job specified by job_id.
-   *
    * [startTime] - Return only metric data that has changed since this time.
    * Default is to return all information about all metrics for the job.
    *
+   * [location] - The location which contains the job specified by job_id.
+   *
    * Completes with a [JobMetrics].
    *
    * 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<JobMetrics> getMetrics(core.String projectId, core.String jobId, {core.String location, core.String startTime}) {
+  async.Future<JobMetrics> getMetrics(core.String projectId, core.String jobId, {core.String startTime, core.String location}) {
     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 (startTime != null) {
+      _queryParams["startTime"] = [startTime];
+    }
     if (location != null) {
       _queryParams["location"] = [location];
     }
-    if (startTime != null) {
-      _queryParams["startTime"] = [startTime];
-    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/metrics';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new JobMetrics.fromJson(data));
   }
 
   /**
    * List the jobs of a project.
    *
    * Request parameters:
    *
    * [projectId] - The project which owns the jobs.
    *
+   * [location] - The location that contains this job.
+   *
+   * [pageToken] - Set this to the 'next_page_token' field of a previous
+   * response
+   * to request additional results in a long list.
+   *
+   * [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.
    *
    * [filter] - The kind of filter to use.
    * Possible string values are:
    * - "UNKNOWN" : A UNKNOWN.
    * - "ALL" : A ALL.
    * - "TERMINATED" : A TERMINATED.
    * - "ACTIVE" : A ACTIVE.
    *
-   * [location] - The location that contains this job.
-   *
-   * [pageToken] - Set this to the 'next_page_token' field of a previous
-   * response
-   * to request additional results in a long list.
-   *
-   * [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.
-   *
    * 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 view, core.String filter, core.String location, core.String pageToken, core.int pageSize}) {
+  async.Future<ListJobsResponse> list(core.String projectId, {core.String location, core.String pageToken, core.int pageSize, core.String view, core.String filter}) {
     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 (filter != null) {
-      _queryParams["filter"] = [filter];
-    }
     if (location != null) {
       _queryParams["location"] = [location];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
+    if (view != null) {
+      _queryParams["view"] = [view];
+    }
+    if (filter != null) {
+      _queryParams["filter"] = [filter];
+    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 172 matching lines @@
 
   /**
    * Request the job status.
    *
    * Request parameters:
    *
    * [projectId] - A project id.
    *
    * [jobId] - The job to get messages about.
    *
+   * [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).
    *
-   * [location] - The location which contains the job specified by job_id.
+   * [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.
-   *
    * 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 endTime, core.String location, core.String pageToken, core.String startTime, core.int pageSize}) {
+  async.Future<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.int pageSize, core.String minimumImportance, core.String location, core.String endTime, core.String startTime, core.String pageToken}) {
     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 (pageSize != null) {
+      _queryParams["pageSize"] = ["${pageSize}"];
+    }
     if (minimumImportance != null) {
       _queryParams["minimumImportance"] = [minimumImportance];
     }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
     if (endTime != null) {
       _queryParams["endTime"] = [endTime];
     }
-    if (location != null) {
-      _queryParams["location"] = [location];
+    if (startTime != null) {
+      _queryParams["startTime"] = [startTime];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
-    if (startTime != null) {
-      _queryParams["startTime"] = [startTime];
-    }
-    if (pageSize != null) {
-      _queryParams["pageSize"] = ["${pageSize}"];
-    }
 
     _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 361 matching lines @@
 
   /**
    * List the jobs of a project.
    *
    * Request parameters:
    *
    * [projectId] - The project which owns the jobs.
    *
    * [location] - The location that contains this job.
    *
-   * [filter] - The kind of filter to use.
-   * Possible string values are:
-   * - "UNKNOWN" : A UNKNOWN.
-   * - "ALL" : A ALL.
-   * - "TERMINATED" : A TERMINATED.
-   * - "ACTIVE" : A ACTIVE.
-   *
    * [pageToken] - Set this to the 'next_page_token' field of a previous
    * response
    * to request additional results in a long list.
    *
    * [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.
    *
+   * [filter] - The kind of filter to use.
+   * Possible string values are:
+   * - "UNKNOWN" : A UNKNOWN.
+   * - "ALL" : A ALL.
+   * - "TERMINATED" : A TERMINATED.
+   * - "ACTIVE" : A ACTIVE.
+   *
    * 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}) {
+  async.Future<ListJobsResponse> list(core.String projectId, core.String location, {core.String pageToken, core.int pageSize, core.String view, core.String filter}) {
     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 (filter != null) {
-      _queryParams["filter"] = [filter];
-    }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (view != null) {
       _queryParams["view"] = [view];
     }
+    if (filter != null) {
+      _queryParams["filter"] = [filter];
+    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 184 matching lines @@
    * Request the job status.
    *
    * Request parameters:
    *
    * [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.
    *
    * [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.
    *
+   * [endTime] - Return only messages with timestamps < end_time. The default is
+   * now
+   * (i.e. return up to the latest messages available).
+   *
    * 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 startTime, core.String pageToken, core.int pageSize, core.String minimumImportance, 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 (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 (startTime != null) {
       _queryParams["startTime"] = [startTime];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (minimumImportance != null) {
       _queryParams["minimumImportance"] = [minimumImportance];
     }
+    if (endTime != null) {
+      _queryParams["endTime"] = [endTime];
+    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 240 matching lines @@
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - Required. The ID of the Cloud Platform project that the job
    * belongs to.
    *
    * [location] - The location to which to direct the request.
    *
-   * [validateOnly] - If true, the request is validated but not actually
-   * executed.
-   * Defaults to false.
-   *
    * [gcsPath] - Required. A Cloud Storage path to the template from which to
    * create
    * the job.
    * Must be valid Cloud Storage URL, beginning with 'gs://'.
    *
+   * [validateOnly] - If true, the request is validated but not actually
+   * executed.
+   * Defaults to false.
+   *
    * 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.String location, {core.bool validateOnly, core.String gcsPath}) {
+  async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request, core.String projectId, core.String location, {core.String gcsPath, core.bool validateOnly}) {
     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 (gcsPath != null) {
+      _queryParams["gcsPath"] = [gcsPath];
+    }
     if (validateOnly != null) {
       _queryParams["validateOnly"] = ["${validateOnly}"];
     }
-    if (gcsPath != null) {
-      _queryParams["gcsPath"] = [gcsPath];
-    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/templates:launch';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 55 matching lines @@
   }
 
   /**
    * Get the template associated with a template.
    *
    * Request parameters:
    *
    * [projectId] - Required. The ID of the Cloud Platform project that the job
    * belongs to.
    *
+   * [location] - The location to which to direct the request.
+   *
    * [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://`.
    *
-   * [location] - The location to which to direct the request.
-   *
    * 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, core.String location}) {
+  async.Future<GetTemplateResponse> get(core.String projectId, {core.String location, 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 (location != null) {
+      _queryParams["location"] = [location];
+    }
     if (view != null) {
       _queryParams["view"] = [view];
     }
     if (gcsPath != null) {
       _queryParams["gcsPath"] = [gcsPath];
     }
-    if (location != null) {
-      _queryParams["location"] = [location];
-    }
 
     _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);
@@ skipping 87 matching lines @@
       percentComplete = _json["percentComplete"];
     }
     if (_json.containsKey("position")) {
       position = new Position.fromJson(_json["position"]);
     }
     if (_json.containsKey("remainingTime")) {
       remainingTime = _json["remainingTime"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (percentComplete != null) {
       _json["percentComplete"] = percentComplete;
     }
     if (position != null) {
       _json["position"] = (position).toJson();
     }
     if (remainingTime != null) {
       _json["remainingTime"] = remainingTime;
     }
     return _json;
@@ skipping 57 matching lines @@
       fractionConsumed = _json["fractionConsumed"];
     }
     if (_json.containsKey("position")) {
       position = new Position.fromJson(_json["position"]);
     }
     if (_json.containsKey("remainingParallelism")) {
       remainingParallelism = new ReportedParallelism.fromJson(_json["remainingParallelism"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (consumedParallelism != null) {
       _json["consumedParallelism"] = (consumedParallelism).toJson();
     }
     if (fractionConsumed != null) {
       _json["fractionConsumed"] = fractionConsumed;
     }
     if (position != null) {
       _json["position"] = (position).toJson();
     }
     if (remainingParallelism != null) {
@@ skipping 19 matching lines @@
 
   ApproximateSplitRequest.fromJson(core.Map _json) {
     if (_json.containsKey("fractionConsumed")) {
       fractionConsumed = _json["fractionConsumed"];
     }
     if (_json.containsKey("position")) {
       position = new Position.fromJson(_json["position"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (fractionConsumed != null) {
       _json["fractionConsumed"] = fractionConsumed;
     }
     if (position != null) {
       _json["position"] = (position).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 55 matching lines @@
       eventType = _json["eventType"];
     }
     if (_json.containsKey("targetNumWorkers")) {
       targetNumWorkers = _json["targetNumWorkers"];
     }
     if (_json.containsKey("time")) {
       time = _json["time"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (currentNumWorkers != null) {
       _json["currentNumWorkers"] = currentNumWorkers;
     }
     if (description != null) {
       _json["description"] = (description).toJson();
     }
     if (eventType != null) {
       _json["eventType"] = eventType;
     }
     if (targetNumWorkers != null) {
@@ skipping 25 matching lines @@
 
   AutoscalingSettings.fromJson(core.Map _json) {
     if (_json.containsKey("algorithm")) {
       algorithm = _json["algorithm"];
     }
     if (_json.containsKey("maxNumWorkers")) {
       maxNumWorkers = _json["maxNumWorkers"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (algorithm != null) {
       _json["algorithm"] = algorithm;
     }
     if (maxNumWorkers != null) {
       _json["maxNumWorkers"] = maxNumWorkers;
     }
     return _json;
   }
 }
 
@@ skipping 19 matching lines @@
       rate = _json["rate"];
     }
     if (_json.containsKey("timestamp")) {
       timestamp = _json["timestamp"];
     }
     if (_json.containsKey("totalMs")) {
       totalMs = _json["totalMs"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (rate != null) {
       _json["rate"] = rate;
     }
     if (timestamp != null) {
       _json["timestamp"] = timestamp;
     }
     if (totalMs != null) {
       _json["totalMs"] = totalMs;
     }
     return _json;
@@ skipping 24 matching lines @@
       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();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (name != null) {
       _json["name"] = name;
     }
     if (originalTransformOrCollection != null) {
       _json["originalTransformOrCollection"] = originalTransformOrCollection;
     }
     if (userName != null) {
       _json["userName"] = userName;
     }
     return _json;
@@ skipping 21 matching lines @@
       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();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (name != null) {
       _json["name"] = name;
     }
     if (originalTransform != null) {
       _json["originalTransform"] = originalTransform;
     }
     if (userName != null) {
       _json["userName"] = userName;
     }
     return _json;
@@ skipping 31 matching lines @@
       outputs = _json["outputs"].map((value) => new StreamLocation.fromJson(value)).toList();
     }
     if (_json.containsKey("stateFamilies")) {
       stateFamilies = _json["stateFamilies"].map((value) => new StateFamilyConfig.fromJson(value)).toList();
     }
     if (_json.containsKey("systemStageName")) {
       systemStageName = _json["systemStageName"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (computationId != null) {
       _json["computationId"] = computationId;
     }
     if (inputs != null) {
       _json["inputs"] = inputs.map((value) => (value).toJson()).toList();
     }
     if (keyRanges != null) {
       _json["keyRanges"] = keyRanges.map((value) => (value).toJson()).toList();
     }
     if (outputs != null) {
@@ skipping 24 matching lines @@
 
   ConcatPosition.fromJson(core.Map _json) {
     if (_json.containsKey("index")) {
       index = _json["index"];
     }
     if (_json.containsKey("position")) {
       position = new Position.fromJson(_json["position"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (index != null) {
       _json["index"] = index;
     }
     if (position != null) {
       _json["position"] = (position).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 46 matching lines @@
       kind = _json["kind"];
     }
     if (_json.containsKey("otherUnits")) {
       otherUnits = _json["otherUnits"];
     }
     if (_json.containsKey("standardUnits")) {
       standardUnits = _json["standardUnits"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (description != null) {
       _json["description"] = description;
     }
     if (kind != null) {
       _json["kind"] = kind;
     }
     if (otherUnits != null) {
       _json["otherUnits"] = otherUnits;
     }
     if (standardUnits != null) {
@@ skipping 67 matching lines @@
       originalStepName = _json["originalStepName"];
     }
     if (_json.containsKey("portion")) {
       portion = _json["portion"];
     }
     if (_json.containsKey("workerId")) {
       workerId = _json["workerId"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (componentStepName != null) {
       _json["componentStepName"] = componentStepName;
     }
     if (executionStepName != null) {
       _json["executionStepName"] = executionStepName;
     }
     if (name != null) {
       _json["name"] = name;
     }
     if (origin != null) {
@@ skipping 29 matching lines @@
 
   CounterStructuredNameAndMetadata.fromJson(core.Map _json) {
     if (_json.containsKey("metadata")) {
       metadata = new CounterMetadata.fromJson(_json["metadata"]);
     }
     if (_json.containsKey("name")) {
       name = new CounterStructuredName.fromJson(_json["name"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (metadata != null) {
       _json["metadata"] = (metadata).toJson();
     }
     if (name != null) {
       _json["name"] = (name).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 82 matching lines @@
       shortId = _json["shortId"];
     }
     if (_json.containsKey("stringList")) {
       stringList = new StringList.fromJson(_json["stringList"]);
     }
     if (_json.containsKey("structuredNameAndMetadata")) {
       structuredNameAndMetadata = new CounterStructuredNameAndMetadata.fromJson(_json["structuredNameAndMetadata"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (boolean != null) {
       _json["boolean"] = boolean;
     }
     if (cumulative != null) {
       _json["cumulative"] = cumulative;
     }
     if (distribution != null) {
       _json["distribution"] = (distribution).toJson();
     }
     if (floatingPoint != null) {
@@ skipping 63 matching lines @@
       jobName = _json["jobName"];
     }
     if (_json.containsKey("location")) {
       location = _json["location"];
     }
     if (_json.containsKey("parameters")) {
       parameters = _json["parameters"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (environment != null) {
       _json["environment"] = (environment).toJson();
     }
     if (gcsPath != null) {
       _json["gcsPath"] = gcsPath;
     }
     if (jobName != null) {
       _json["jobName"] = jobName;
     }
     if (location != null) {
@@ skipping 12 matching lines @@
   core.bool stateful;
 
   CustomSourceLocation();
 
   CustomSourceLocation.fromJson(core.Map _json) {
     if (_json.containsKey("stateful")) {
       stateful = _json["stateful"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (stateful != null) {
       _json["stateful"] = stateful;
     }
     return _json;
   }
 }
 
 /** Data disk assignment for a given VM instance. */
 class DataDiskAssignment {
   /**
@@ skipping 13 matching lines @@
 
   DataDiskAssignment.fromJson(core.Map _json) {
     if (_json.containsKey("dataDisks")) {
       dataDisks = _json["dataDisks"];
     }
     if (_json.containsKey("vmInstance")) {
       vmInstance = _json["vmInstance"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (dataDisks != null) {
       _json["dataDisks"] = dataDisks;
     }
     if (vmInstance != null) {
       _json["vmInstance"] = vmInstance;
     }
     return _json;
   }
 }
 
@@ skipping 24 matching lines @@
 
   DerivedSource.fromJson(core.Map _json) {
     if (_json.containsKey("derivationMode")) {
       derivationMode = _json["derivationMode"];
     }
     if (_json.containsKey("source")) {
       source = new Source.fromJson(_json["source"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (derivationMode != null) {
       _json["derivationMode"] = derivationMode;
     }
     if (source != null) {
       _json["source"] = (source).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 35 matching lines @@
       diskType = _json["diskType"];
     }
     if (_json.containsKey("mountPoint")) {
       mountPoint = _json["mountPoint"];
     }
     if (_json.containsKey("sizeGb")) {
       sizeGb = _json["sizeGb"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (diskType != null) {
       _json["diskType"] = diskType;
     }
     if (mountPoint != null) {
       _json["mountPoint"] = mountPoint;
     }
     if (sizeGb != null) {
       _json["sizeGb"] = sizeGb;
     }
     return _json;
@@ skipping 77 matching lines @@
       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();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (boolValue != null) {
       _json["boolValue"] = boolValue;
     }
     if (durationValue != null) {
       _json["durationValue"] = durationValue;
     }
     if (floatValue != null) {
       _json["floatValue"] = floatValue;
     }
     if (int64Value != null) {
@@ skipping 64 matching lines @@
       min = new SplitInt64.fromJson(_json["min"]);
     }
     if (_json.containsKey("sum")) {
       sum = new SplitInt64.fromJson(_json["sum"]);
     }
     if (_json.containsKey("sumOfSquares")) {
       sumOfSquares = _json["sumOfSquares"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (count != null) {
       _json["count"] = (count).toJson();
     }
     if (logBuckets != null) {
       _json["logBuckets"] = logBuckets.map((value) => (value).toJson()).toList();
     }
     if (max != null) {
       _json["max"] = (max).toJson();
     }
     if (min != null) {
@@ skipping 31 matching lines @@
 
   DynamicSourceSplit.fromJson(core.Map _json) {
     if (_json.containsKey("primary")) {
       primary = new DerivedSource.fromJson(_json["primary"]);
     }
     if (_json.containsKey("residual")) {
       residual = new DerivedSource.fromJson(_json["residual"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (primary != null) {
       _json["primary"] = (primary).toJson();
     }
     if (residual != null) {
       _json["residual"] = (residual).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 102 matching lines @@
       userAgent = _json["userAgent"];
     }
     if (_json.containsKey("version")) {
       version = _json["version"];
     }
     if (_json.containsKey("workerPools")) {
       workerPools = _json["workerPools"].map((value) => new WorkerPool.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (clusterManagerApiService != null) {
       _json["clusterManagerApiService"] = clusterManagerApiService;
     }
     if (dataset != null) {
       _json["dataset"] = dataset;
     }
     if (experiments != null) {
       _json["experiments"] = experiments;
     }
     if (internalExperiments != null) {
@@ skipping 87 matching lines @@
       currentStateTime = _json["currentStateTime"];
     }
     if (_json.containsKey("executionStageName")) {
       executionStageName = _json["executionStageName"];
     }
     if (_json.containsKey("executionStageState")) {
       executionStageState = _json["executionStageState"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (currentStateTime != null) {
       _json["currentStateTime"] = currentStateTime;
     }
     if (executionStageName != null) {
       _json["executionStageName"] = executionStageName;
     }
     if (executionStageState != null) {
       _json["executionStageState"] = executionStageState;
     }
     return _json;
@@ skipping 56 matching lines @@
       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();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     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) {
@@ skipping 18 matching lines @@
   core.String name;
 
   FailedLocation();
 
   FailedLocation.fromJson(core.Map _json) {
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (name != null) {
       _json["name"] = name;
     }
     return _json;
   }
 }
 
 /**
  * An instruction that copies its inputs (zero or more) to its (single) output.
  */
 class FlattenInstruction {
   /** Describes the inputs to the flatten instruction. */
   core.List<InstructionInput> inputs;
 
   FlattenInstruction();
 
   FlattenInstruction.fromJson(core.Map _json) {
     if (_json.containsKey("inputs")) {
       inputs = _json["inputs"].map((value) => new InstructionInput.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (inputs != null) {
       _json["inputs"] = inputs.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /** A metric value representing a list of floating point numbers. */
 class FloatingPointList {
   /** Elements of the list. */
   core.List<core.double> elements;
 
   FloatingPointList();
 
   FloatingPointList.fromJson(core.Map _json) {
     if (_json.containsKey("elements")) {
       elements = _json["elements"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (elements != null) {
       _json["elements"] = elements;
     }
     return _json;
   }
 }
 
 /** A representation of a floating point mean metric contribution. */
 class FloatingPointMean {
   /** The number of values being aggregated. */
   SplitInt64 count;
   /** The sum of all values being aggregated. */
   core.double sum;
 
   FloatingPointMean();
 
   FloatingPointMean.fromJson(core.Map _json) {
     if (_json.containsKey("count")) {
       count = new SplitInt64.fromJson(_json["count"]);
     }
     if (_json.containsKey("sum")) {
       sum = _json["sum"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (count != null) {
       _json["count"] = (count).toJson();
     }
     if (sum != null) {
       _json["sum"] = sum;
     }
     return _json;
   }
 }
 
@@ skipping 16 matching lines @@
       componentId = _json["componentId"];
     }
     if (_json.containsKey("location")) {
       location = _json["location"];
     }
     if (_json.containsKey("workerId")) {
       workerId = _json["workerId"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (componentId != null) {
       _json["componentId"] = componentId;
     }
     if (location != null) {
       _json["location"] = location;
     }
     if (workerId != null) {
       _json["workerId"] = workerId;
     }
     return _json;
   }
 }
 
 /** Response to a get debug configuration request. */
 class GetDebugConfigResponse {
   /** The encoded debug configuration for the requested component. */
   core.String config;
 
   GetDebugConfigResponse();
 
   GetDebugConfigResponse.fromJson(core.Map _json) {
     if (_json.containsKey("config")) {
       config = _json["config"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (config != null) {
       _json["config"] = config;
     }
     return _json;
   }
 }
 
 /** The response to a GetTemplate request. */
 class GetTemplateResponse {
   /**
@@ skipping 11 matching lines @@
 
   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();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (metadata != null) {
       _json["metadata"] = (metadata).toJson();
     }
     if (status != null) {
       _json["status"] = (status).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 16 matching lines @@
 
   InstructionInput.fromJson(core.Map _json) {
     if (_json.containsKey("outputNum")) {
       outputNum = _json["outputNum"];
     }
     if (_json.containsKey("producerInstructionIndex")) {
       producerInstructionIndex = _json["producerInstructionIndex"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (outputNum != null) {
       _json["outputNum"] = outputNum;
     }
     if (producerInstructionIndex != null) {
       _json["producerInstructionIndex"] = producerInstructionIndex;
     }
     return _json;
   }
 }
 
@@ skipping 45 matching lines @@
       onlyCountValueBytes = _json["onlyCountValueBytes"];
     }
     if (_json.containsKey("originalName")) {
       originalName = _json["originalName"];
     }
     if (_json.containsKey("systemName")) {
       systemName = _json["systemName"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (codec != null) {
       _json["codec"] = codec;
     }
     if (name != null) {
       _json["name"] = name;
     }
     if (onlyCountKeyBytes != null) {
       _json["onlyCountKeyBytes"] = onlyCountKeyBytes;
     }
     if (onlyCountValueBytes != null) {
@@ skipping 15 matching lines @@
   core.List<SplitInt64> elements;
 
   IntegerList();
 
   IntegerList.fromJson(core.Map _json) {
     if (_json.containsKey("elements")) {
       elements = _json["elements"].map((value) => new SplitInt64.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (elements != null) {
       _json["elements"] = elements.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /** A representation of an integer mean metric contribution. */
 class IntegerMean {
   /** The number of values being aggregated. */
   SplitInt64 count;
   /** The sum of all values being aggregated. */
   SplitInt64 sum;
 
   IntegerMean();
 
   IntegerMean.fromJson(core.Map _json) {
     if (_json.containsKey("count")) {
       count = new SplitInt64.fromJson(_json["count"]);
     }
     if (_json.containsKey("sum")) {
       sum = new SplitInt64.fromJson(_json["sum"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (count != null) {
       _json["count"] = (count).toJson();
     }
     if (sum != null) {
       _json["sum"] = (sum).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 294 matching lines @@
       tempFiles = _json["tempFiles"];
     }
     if (_json.containsKey("transformNameMapping")) {
       transformNameMapping = _json["transformNameMapping"];
     }
     if (_json.containsKey("type")) {
       type = _json["type"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (clientRequestId != null) {
       _json["clientRequestId"] = clientRequestId;
     }
     if (createTime != null) {
       _json["createTime"] = createTime;
     }
     if (currentState != null) {
       _json["currentState"] = currentState;
     }
     if (currentStateTime != null) {
@@ skipping 56 matching lines @@
  * isn't contained in the submitted job.
  */
 class JobExecutionInfo {
   /** A mapping from each stage to the information about that stage. */
   core.Map<core.String, JobExecutionStageInfo> stages;
 
   JobExecutionInfo();
 
   JobExecutionInfo.fromJson(core.Map _json) {
     if (_json.containsKey("stages")) {
-      stages = commons.mapMap(_json["stages"], (item) => new JobExecutionStageInfo.fromJson(item));
+      stages = commons.mapMap<core.Map<core.String, core.Object>, JobExecutionStageInfo>(_json["stages"], (core.Map<core.String, core.Object> item) => new JobExecutionStageInfo.fromJson(item));
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (stages != null) {
-      _json["stages"] = commons.mapMap(stages, (item) => (item).toJson());
+      _json["stages"] = commons.mapMap<JobExecutionStageInfo, core.Map<core.String, core.Object>>(stages, (JobExecutionStageInfo item) => (item).toJson());
     }
     return _json;
   }
 }
 
 /**
  * Contains information about how a particular
  * google.dataflow.v1beta3.Step will be executed.
  */
 class JobExecutionStageInfo {
   /**
    * The steps associated with the execution stage.
    * Note that stages may have several steps, and that a given step
    * might be run by more than one stage.
    */
   core.List<core.String> stepName;
 
   JobExecutionStageInfo();
 
   JobExecutionStageInfo.fromJson(core.Map _json) {
     if (_json.containsKey("stepName")) {
       stepName = _json["stepName"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (stepName != null) {
       _json["stepName"] = stepName;
     }
     return _json;
   }
 }
 
 /** A particular message pertaining to a Dataflow job. */
 class JobMessage {
   /** Deprecated. */
@@ skipping 48 matching lines @@
       messageImportance = _json["messageImportance"];
     }
     if (_json.containsKey("messageText")) {
       messageText = _json["messageText"];
     }
     if (_json.containsKey("time")) {
       time = _json["time"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (id != null) {
       _json["id"] = id;
     }
     if (messageImportance != null) {
       _json["messageImportance"] = messageImportance;
     }
     if (messageText != null) {
       _json["messageText"] = messageText;
     }
     if (time != null) {
@@ skipping 22 matching lines @@
 
   JobMetrics.fromJson(core.Map _json) {
     if (_json.containsKey("metricTime")) {
       metricTime = _json["metricTime"];
     }
     if (_json.containsKey("metrics")) {
       metrics = _json["metrics"].map((value) => new MetricUpdate.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (metricTime != null) {
       _json["metricTime"] = metricTime;
     }
     if (metrics != null) {
       _json["metrics"] = metrics.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
@@ skipping 23 matching lines @@
       dataDisk = _json["dataDisk"];
     }
     if (_json.containsKey("end")) {
       end = _json["end"];
     }
     if (_json.containsKey("start")) {
       start = _json["start"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (dataDisk != null) {
       _json["dataDisk"] = dataDisk;
     }
     if (end != null) {
       _json["end"] = end;
     }
     if (start != null) {
       _json["start"] = start;
     }
     return _json;
@@ skipping 41 matching lines @@
       deprecatedPersistentDirectory = _json["deprecatedPersistentDirectory"];
     }
     if (_json.containsKey("end")) {
       end = _json["end"];
     }
     if (_json.containsKey("start")) {
       start = _json["start"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (dataDisk != null) {
       _json["dataDisk"] = dataDisk;
     }
     if (deliveryEndpoint != null) {
       _json["deliveryEndpoint"] = deliveryEndpoint;
     }
     if (deprecatedPersistentDirectory != null) {
       _json["deprecatedPersistentDirectory"] = deprecatedPersistentDirectory;
     }
     if (end != null) {
@@ skipping 22 matching lines @@
       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();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     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;
 
   LaunchTemplateResponse();
 
   LaunchTemplateResponse.fromJson(core.Map _json) {
     if (_json.containsKey("job")) {
       job = new Job.fromJson(_json["job"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (job != null) {
       _json["job"] = (job).toJson();
     }
     return _json;
   }
 }
 
 /** Request to lease WorkItems. */
 class LeaseWorkItemRequest {
   /** The current timestamp at the worker. */
@@ skipping 31 matching lines @@
       workItemTypes = _json["workItemTypes"];
     }
     if (_json.containsKey("workerCapabilities")) {
       workerCapabilities = _json["workerCapabilities"];
     }
     if (_json.containsKey("workerId")) {
       workerId = _json["workerId"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (currentWorkerTime != null) {
       _json["currentWorkerTime"] = currentWorkerTime;
     }
     if (location != null) {
       _json["location"] = location;
     }
     if (requestedLeaseDuration != null) {
       _json["requestedLeaseDuration"] = requestedLeaseDuration;
     }
     if (workItemTypes != null) {
@@ skipping 15 matching lines @@
   core.List<WorkItem> workItems;
 
   LeaseWorkItemResponse();
 
   LeaseWorkItemResponse.fromJson(core.Map _json) {
     if (_json.containsKey("workItems")) {
       workItems = _json["workItems"].map((value) => new WorkItem.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (workItems != null) {
       _json["workItems"] = workItems.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /** Response to a request to list job messages. */
 class ListJobMessagesResponse {
   /** Autoscaling events in ascending timestamp order. */
@@ skipping 10 matching lines @@
       autoscalingEvents = _json["autoscalingEvents"].map((value) => new AutoscalingEvent.fromJson(value)).toList();
     }
     if (_json.containsKey("jobMessages")) {
       jobMessages = _json["jobMessages"].map((value) => new JobMessage.fromJson(value)).toList();
     }
     if (_json.containsKey("nextPageToken")) {
       nextPageToken = _json["nextPageToken"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (autoscalingEvents != null) {
       _json["autoscalingEvents"] = autoscalingEvents.map((value) => (value).toJson()).toList();
     }
     if (jobMessages != null) {
       _json["jobMessages"] = jobMessages.map((value) => (value).toJson()).toList();
     }
     if (nextPageToken != null) {
       _json["nextPageToken"] = nextPageToken;
     }
     return _json;
@@ skipping 19 matching lines @@
       failedLocation = _json["failedLocation"].map((value) => new FailedLocation.fromJson(value)).toList();
     }
     if (_json.containsKey("jobs")) {
       jobs = _json["jobs"].map((value) => new Job.fromJson(value)).toList();
     }
     if (_json.containsKey("nextPageToken")) {
       nextPageToken = _json["nextPageToken"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (failedLocation != null) {
       _json["failedLocation"] = failedLocation.map((value) => (value).toJson()).toList();
     }
     if (jobs != null) {
       _json["jobs"] = jobs.map((value) => (value).toJson()).toList();
     }
     if (nextPageToken != null) {
       _json["nextPageToken"] = nextPageToken;
     }
     return _json;
@@ skipping 20 matching lines @@
 
   LogBucket.fromJson(core.Map _json) {
     if (_json.containsKey("count")) {
       count = _json["count"];
     }
     if (_json.containsKey("log")) {
       log = _json["log"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (count != null) {
       _json["count"] = count;
     }
     if (log != null) {
       _json["log"] = log;
     }
     return _json;
   }
 }
 
@@ skipping 26 matching lines @@
       instructions = _json["instructions"].map((value) => new ParallelInstruction.fromJson(value)).toList();
     }
     if (_json.containsKey("stageName")) {
       stageName = _json["stageName"];
     }
     if (_json.containsKey("systemName")) {
       systemName = _json["systemName"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (instructions != null) {
       _json["instructions"] = instructions.map((value) => (value).toJson()).toList();
     }
     if (stageName != null) {
       _json["stageName"] = stageName;
     }
     if (systemName != null) {
       _json["systemName"] = systemName;
     }
     return _json;
@@ skipping 17 matching lines @@
 
   MetricShortId.fromJson(core.Map _json) {
     if (_json.containsKey("metricIndex")) {
       metricIndex = _json["metricIndex"];
     }
     if (_json.containsKey("shortId")) {
       shortId = _json["shortId"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (metricIndex != null) {
       _json["metricIndex"] = metricIndex;
     }
     if (shortId != null) {
       _json["shortId"] = shortId;
     }
     return _json;
   }
 }
 
@@ skipping 26 matching lines @@
       context = _json["context"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
     if (_json.containsKey("origin")) {
       origin = _json["origin"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (context != null) {
       _json["context"] = context;
     }
     if (name != null) {
       _json["name"] = name;
     }
     if (origin != null) {
       _json["origin"] = origin;
     }
     return _json;
@@ skipping 108 matching lines @@
       scalar = _json["scalar"];
     }
     if (_json.containsKey("set")) {
       set = _json["set"];
     }
     if (_json.containsKey("updateTime")) {
       updateTime = _json["updateTime"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (cumulative != null) {
       _json["cumulative"] = cumulative;
     }
     if (distribution != null) {
       _json["distribution"] = distribution;
     }
     if (internal != null) {
       _json["internal"] = internal;
     }
     if (kind != null) {
@@ skipping 32 matching lines @@
   core.String dataDisk;
 
   MountedDataDisk();
 
   MountedDataDisk.fromJson(core.Map _json) {
     if (_json.containsKey("dataDisk")) {
       dataDisk = _json["dataDisk"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (dataDisk != null) {
       _json["dataDisk"] = dataDisk;
     }
     return _json;
   }
 }
 
 /** Information about an output of a multi-output DoFn. */
 class MultiOutputInfo {
   /**
    * The id of the tag the user code will emit to this output by; this
    * should correspond to the tag of some SideInputInfo.
    */
   core.String tag;
 
   MultiOutputInfo();
 
   MultiOutputInfo.fromJson(core.Map _json) {
     if (_json.containsKey("tag")) {
       tag = _json["tag"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (tag != null) {
       _json["tag"] = tag;
     }
     return _json;
   }
 }
 
 /** Basic metadata about a counter. */
 class NameAndKind {
   /**
@@ skipping 20 matching lines @@
 
   NameAndKind.fromJson(core.Map _json) {
     if (_json.containsKey("kind")) {
       kind = _json["kind"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (kind != null) {
       _json["kind"] = kind;
     }
     if (name != null) {
       _json["name"] = name;
     }
     return _json;
   }
 }
 
@@ skipping 25 matching lines @@
 
   Package.fromJson(core.Map _json) {
     if (_json.containsKey("location")) {
       location = _json["location"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (location != null) {
       _json["location"] = location;
     }
     if (name != null) {
       _json["name"] = name;
     }
     return _json;
   }
 }
 
@@ skipping 33 matching lines @@
       numOutputs = _json["numOutputs"];
     }
     if (_json.containsKey("sideInputs")) {
       sideInputs = _json["sideInputs"].map((value) => new SideInputInfo.fromJson(value)).toList();
     }
     if (_json.containsKey("userFn")) {
       userFn = _json["userFn"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (multiOutputInfos != null) {
       _json["multiOutputInfos"] = multiOutputInfos.map((value) => (value).toJson()).toList();
     }
     if (numOutputs != null) {
       _json["numOutputs"] = numOutputs;
     }
     if (sideInputs != null) {
@@ skipping 55 matching lines @@
       read = new ReadInstruction.fromJson(_json["read"]);
     }
     if (_json.containsKey("systemName")) {
       systemName = _json["systemName"];
     }
     if (_json.containsKey("write")) {
       write = new WriteInstruction.fromJson(_json["write"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (flatten != null) {
       _json["flatten"] = (flatten).toJson();
     }
     if (name != null) {
       _json["name"] = name;
     }
     if (originalName != null) {
       _json["originalName"] = originalName;
     }
     if (outputs != null) {
@@ skipping 34 matching lines @@
 
   Parameter.fromJson(core.Map _json) {
     if (_json.containsKey("key")) {
       key = _json["key"];
     }
     if (_json.containsKey("value")) {
       value = _json["value"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (key != null) {
       _json["key"] = key;
     }
     if (value != null) {
       _json["value"] = value;
     }
     return _json;
   }
 }
 
@@ skipping 23 matching lines @@
       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();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (helpText != null) {
       _json["helpText"] = helpText;
     }
     if (isOptional != null) {
       _json["isOptional"] = isOptional;
     }
     if (label != null) {
       _json["label"] = label;
     }
     if (name != null) {
@@ skipping 56 matching lines @@
       originalCombineValuesStepName = _json["originalCombineValuesStepName"];
     }
     if (_json.containsKey("sideInputs")) {
       sideInputs = _json["sideInputs"].map((value) => new SideInputInfo.fromJson(value)).toList();
     }
     if (_json.containsKey("valueCombiningFn")) {
       valueCombiningFn = _json["valueCombiningFn"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (inputElementCodec != null) {
       _json["inputElementCodec"] = inputElementCodec;
     }
     if (originalCombineValuesInputStoreName != null) {
       _json["originalCombineValuesInputStoreName"] = originalCombineValuesInputStoreName;
     }
     if (originalCombineValuesStepName != null) {
@@ skipping 31 matching lines @@
       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();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     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;
@@ skipping 41 matching lines @@
       key = _json["key"];
     }
     if (_json.containsKey("recordIndex")) {
       recordIndex = _json["recordIndex"];
     }
     if (_json.containsKey("shufflePosition")) {
       shufflePosition = _json["shufflePosition"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (byteOffset != null) {
       _json["byteOffset"] = byteOffset;
     }
     if (concatPosition != null) {
       _json["concatPosition"] = (concatPosition).toJson();
     }
     if (end != null) {
       _json["end"] = end;
     }
     if (key != null) {
@@ skipping 63 matching lines @@
       topic = _json["topic"];
     }
     if (_json.containsKey("trackingSubscription")) {
       trackingSubscription = _json["trackingSubscription"];
     }
     if (_json.containsKey("withAttributes")) {
       withAttributes = _json["withAttributes"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (dropLateData != null) {
       _json["dropLateData"] = dropLateData;
     }
     if (idLabel != null) {
       _json["idLabel"] = idLabel;
     }
     if (subscription != null) {
       _json["subscription"] = subscription;
     }
     if (timestampLabel != null) {
@@ skipping 21 matching lines @@
   Source source;
 
   ReadInstruction();
 
   ReadInstruction.fromJson(core.Map _json) {
     if (_json.containsKey("source")) {
       source = new Source.fromJson(_json["source"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (source != null) {
       _json["source"] = (source).toJson();
     }
     return _json;
   }
 }
 
 /** Request to report the status of WorkItems. */
 class ReportWorkItemStatusRequest {
   /** The current timestamp at the worker. */
@@ skipping 24 matching lines @@
       location = _json["location"];
     }
     if (_json.containsKey("workItemStatuses")) {
       workItemStatuses = _json["workItemStatuses"].map((value) => new WorkItemStatus.fromJson(value)).toList();
     }
     if (_json.containsKey("workerId")) {
       workerId = _json["workerId"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (currentWorkerTime != null) {
       _json["currentWorkerTime"] = currentWorkerTime;
     }
     if (location != null) {
       _json["location"] = location;
     }
     if (workItemStatuses != null) {
       _json["workItemStatuses"] = workItemStatuses.map((value) => (value).toJson()).toList();
     }
     if (workerId != null) {
@@ skipping 14 matching lines @@
   core.List<WorkItemServiceState> workItemServiceStates;
 
   ReportWorkItemStatusResponse();
 
   ReportWorkItemStatusResponse.fromJson(core.Map _json) {
     if (_json.containsKey("workItemServiceStates")) {
       workItemServiceStates = _json["workItemServiceStates"].map((value) => new WorkItemServiceState.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (workItemServiceStates != null) {
       _json["workItemServiceStates"] = workItemServiceStates.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /**
  * Represents the level of parallelism in a WorkItem's input,
  * reported by the worker.
@@ skipping 15 matching lines @@
 
   ReportedParallelism.fromJson(core.Map _json) {
     if (_json.containsKey("isInfinite")) {
       isInfinite = _json["isInfinite"];
     }
     if (_json.containsKey("value")) {
       value = _json["value"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (isInfinite != null) {
       _json["isInfinite"] = isInfinite;
     }
     if (value != null) {
       _json["value"] = value;
     }
     return _json;
   }
 }
 
 /**
  * Worker metrics exported from workers. This contains resource utilization
  * metrics accumulated from a variety of sources. For more information, see
  * go/df-resource-signals.
  */
 class ResourceUtilizationReport {
   /** CPU utilization samples. */
   core.List<CPUTime> cpuTime;
 
   ResourceUtilizationReport();
 
   ResourceUtilizationReport.fromJson(core.Map _json) {
     if (_json.containsKey("cpuTime")) {
       cpuTime = _json["cpuTime"].map((value) => new CPUTime.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (cpuTime != null) {
       _json["cpuTime"] = cpuTime.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /** Service-side response to WorkerMessage reporting resource utilization. */
 class ResourceUtilizationReportResponse {
 
   ResourceUtilizationReportResponse();
 
   ResourceUtilizationReportResponse.fromJson(core.Map _json) {
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     return _json;
   }
 }
 
 /** The environment values to set at runtime. */
 class RuntimeEnvironment {
   /**
    * Whether to bypass the safety checks for the job's temporary directory.
    * Use with caution.
    */
@@ skipping 38 matching lines @@
       serviceAccountEmail = _json["serviceAccountEmail"];
     }
     if (_json.containsKey("tempLocation")) {
       tempLocation = _json["tempLocation"];
     }
     if (_json.containsKey("zone")) {
       zone = _json["zone"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (bypassTempDirValidation != null) {
       _json["bypassTempDirValidation"] = bypassTempDirValidation;
     }
     if (machineType != null) {
       _json["machineType"] = machineType;
     }
     if (maxWorkers != null) {
       _json["maxWorkers"] = maxWorkers;
     }
     if (serviceAccountEmail != null) {
@@ skipping 30 matching lines @@
       data = _json["data"];
     }
     if (_json.containsKey("location")) {
       location = _json["location"];
     }
     if (_json.containsKey("workerId")) {
       workerId = _json["workerId"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (componentId != null) {
       _json["componentId"] = componentId;
     }
     if (data != null) {
       _json["data"] = data;
     }
     if (location != null) {
       _json["location"] = location;
     }
     if (workerId != null) {
       _json["workerId"] = workerId;
     }
     return _json;
   }
 }
 
 /**
  * Response to a send capture request.
  * nothing
  */
 class SendDebugCaptureResponse {
 
   SendDebugCaptureResponse();
 
   SendDebugCaptureResponse.fromJson(core.Map _json) {
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     return _json;
   }
 }
 
 /** A request for sending worker messages to the service. */
 class SendWorkerMessagesRequest {
   /** The location which contains the job */
   core.String location;
   /** The WorkerMessages to send. */
   core.List<WorkerMessage> workerMessages;
 
   SendWorkerMessagesRequest();
 
   SendWorkerMessagesRequest.fromJson(core.Map _json) {
     if (_json.containsKey("location")) {
       location = _json["location"];
     }
     if (_json.containsKey("workerMessages")) {
       workerMessages = _json["workerMessages"].map((value) => new WorkerMessage.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (location != null) {
       _json["location"] = location;
     }
     if (workerMessages != null) {
       _json["workerMessages"] = workerMessages.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /** The response to the worker messages. */
 class SendWorkerMessagesResponse {
   /** The servers response to the worker messages. */
   core.List<WorkerMessageResponse> workerMessageResponses;
 
   SendWorkerMessagesResponse();
 
   SendWorkerMessagesResponse.fromJson(core.Map _json) {
     if (_json.containsKey("workerMessageResponses")) {
       workerMessageResponses = _json["workerMessageResponses"].map((value) => new WorkerMessageResponse.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (workerMessageResponses != null) {
       _json["workerMessageResponses"] = workerMessageResponses.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /** Describes a particular function to invoke. */
 class SeqMapTask {
   /** Information about each of the inputs. */
@@ skipping 36 matching lines @@
       stageName = _json["stageName"];
     }
     if (_json.containsKey("systemName")) {
       systemName = _json["systemName"];
     }
     if (_json.containsKey("userFn")) {
       userFn = _json["userFn"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (inputs != null) {
       _json["inputs"] = inputs.map((value) => (value).toJson()).toList();
     }
     if (name != null) {
       _json["name"] = name;
     }
     if (outputInfos != null) {
       _json["outputInfos"] = outputInfos.map((value) => (value).toJson()).toList();
     }
     if (stageName != null) {
@@ skipping 20 matching lines @@
 
   SeqMapTaskOutputInfo.fromJson(core.Map _json) {
     if (_json.containsKey("sink")) {
       sink = new Sink.fromJson(_json["sink"]);
     }
     if (_json.containsKey("tag")) {
       tag = _json["tag"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     if (tag != null) {
       _json["tag"] = tag;
     }
     return _json;
   }
 }
 
 /** A task which consists of a shell command for the worker to execute. */
 class ShellTask {
   /** The shell command to run. */
   core.String command;
   /** Exit code for the task. */
   core.int exitCode;
 
   ShellTask();
 
   ShellTask.fromJson(core.Map _json) {
     if (_json.containsKey("command")) {
       command = _json["command"];
     }
     if (_json.containsKey("exitCode")) {
       exitCode = _json["exitCode"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (command != null) {
       _json["command"] = command;
     }
     if (exitCode != null) {
       _json["exitCode"] = exitCode;
     }
     return _json;
   }
 }
 
@@ skipping 26 matching lines @@
       kind = _json["kind"];
     }
     if (_json.containsKey("sources")) {
       sources = _json["sources"].map((value) => new Source.fromJson(value)).toList();
     }
     if (_json.containsKey("tag")) {
       tag = _json["tag"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (kind != null) {
       _json["kind"] = kind;
     }
     if (sources != null) {
       _json["sources"] = sources.map((value) => (value).toJson()).toList();
     }
     if (tag != null) {
       _json["tag"] = tag;
     }
     return _json;
@@ skipping 21 matching lines @@
 
   Sink.fromJson(core.Map _json) {
     if (_json.containsKey("codec")) {
       codec = _json["codec"];
     }
     if (_json.containsKey("spec")) {
       spec = _json["spec"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (codec != null) {
       _json["codec"] = codec;
     }
     if (spec != null) {
       _json["spec"] = spec;
     }
     return _json;
   }
 }
 
@@ skipping 71 matching lines @@
       doesNotNeedSplitting = _json["doesNotNeedSplitting"];
     }
     if (_json.containsKey("metadata")) {
       metadata = new SourceMetadata.fromJson(_json["metadata"]);
     }
     if (_json.containsKey("spec")) {
       spec = _json["spec"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (baseSpecs != null) {
       _json["baseSpecs"] = baseSpecs;
     }
     if (codec != null) {
       _json["codec"] = codec;
     }
     if (doesNotNeedSplitting != null) {
       _json["doesNotNeedSplitting"] = doesNotNeedSplitting;
     }
     if (metadata != null) {
@@ skipping 27 matching lines @@
       primarySource = new DerivedSource.fromJson(_json["primarySource"]);
     }
     if (_json.containsKey("residual")) {
       residual = new SourceSplitShard.fromJson(_json["residual"]);
     }
     if (_json.containsKey("residualSource")) {
       residualSource = new DerivedSource.fromJson(_json["residualSource"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (primary != null) {
       _json["primary"] = (primary).toJson();
     }
     if (primarySource != null) {
       _json["primarySource"] = (primarySource).toJson();
     }
     if (residual != null) {
       _json["residual"] = (residual).toJson();
     }
     if (residualSource != null) {
       _json["residualSource"] = (residualSource).toJson();
     }
     return _json;
   }
 }
 
 /** A request to compute the SourceMetadata of a Source. */
 class SourceGetMetadataRequest {
   /** Specification of the source whose metadata should be computed. */
   Source source;
 
   SourceGetMetadataRequest();
 
   SourceGetMetadataRequest.fromJson(core.Map _json) {
     if (_json.containsKey("source")) {
       source = new Source.fromJson(_json["source"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (source != null) {
       _json["source"] = (source).toJson();
     }
     return _json;
   }
 }
 
 /** The result of a SourceGetMetadataOperation. */
 class SourceGetMetadataResponse {
   /** The computed metadata. */
   SourceMetadata metadata;
 
   SourceGetMetadataResponse();
 
   SourceGetMetadataResponse.fromJson(core.Map _json) {
     if (_json.containsKey("metadata")) {
       metadata = new SourceMetadata.fromJson(_json["metadata"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (metadata != null) {
       _json["metadata"] = (metadata).toJson();
     }
     return _json;
   }
 }
 
 /**
  * Metadata about a Source useful for automatically optimizing
  * and tuning the pipeline, etc.
@@ skipping 23 matching lines @@
       estimatedSizeBytes = _json["estimatedSizeBytes"];
     }
     if (_json.containsKey("infinite")) {
       infinite = _json["infinite"];
     }
     if (_json.containsKey("producesSortedKeys")) {
       producesSortedKeys = _json["producesSortedKeys"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (estimatedSizeBytes != null) {
       _json["estimatedSizeBytes"] = estimatedSizeBytes;
     }
     if (infinite != null) {
       _json["infinite"] = infinite;
     }
     if (producesSortedKeys != null) {
       _json["producesSortedKeys"] = producesSortedKeys;
     }
     return _json;
@@ skipping 14 matching lines @@
 
   SourceOperationRequest.fromJson(core.Map _json) {
     if (_json.containsKey("getMetadata")) {
       getMetadata = new SourceGetMetadataRequest.fromJson(_json["getMetadata"]);
     }
     if (_json.containsKey("split")) {
       split = new SourceSplitRequest.fromJson(_json["split"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (getMetadata != null) {
       _json["getMetadata"] = (getMetadata).toJson();
     }
     if (split != null) {
       _json["split"] = (split).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 12 matching lines @@
 
   SourceOperationResponse.fromJson(core.Map _json) {
     if (_json.containsKey("getMetadata")) {
       getMetadata = new SourceGetMetadataResponse.fromJson(_json["getMetadata"]);
     }
     if (_json.containsKey("split")) {
       split = new SourceSplitResponse.fromJson(_json["split"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (getMetadata != null) {
       _json["getMetadata"] = (getMetadata).toJson();
     }
     if (split != null) {
       _json["split"] = (split).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 14 matching lines @@
 
   SourceSplitOptions.fromJson(core.Map _json) {
     if (_json.containsKey("desiredBundleSizeBytes")) {
       desiredBundleSizeBytes = _json["desiredBundleSizeBytes"];
     }
     if (_json.containsKey("desiredShardSizeBytes")) {
       desiredShardSizeBytes = _json["desiredShardSizeBytes"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (desiredBundleSizeBytes != null) {
       _json["desiredBundleSizeBytes"] = desiredBundleSizeBytes;
     }
     if (desiredShardSizeBytes != null) {
       _json["desiredShardSizeBytes"] = desiredShardSizeBytes;
     }
     return _json;
   }
 }
 
@@ skipping 23 matching lines @@
 
   SourceSplitRequest.fromJson(core.Map _json) {
     if (_json.containsKey("options")) {
       options = new SourceSplitOptions.fromJson(_json["options"]);
     }
     if (_json.containsKey("source")) {
       source = new Source.fromJson(_json["source"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (options != null) {
       _json["options"] = (options).toJson();
     }
     if (source != null) {
       _json["source"] = (source).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 30 matching lines @@
       bundles = _json["bundles"].map((value) => new DerivedSource.fromJson(value)).toList();
     }
     if (_json.containsKey("outcome")) {
       outcome = _json["outcome"];
     }
     if (_json.containsKey("shards")) {
       shards = _json["shards"].map((value) => new SourceSplitShard.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (bundles != null) {
       _json["bundles"] = bundles.map((value) => (value).toJson()).toList();
     }
     if (outcome != null) {
       _json["outcome"] = outcome;
     }
     if (shards != null) {
       _json["shards"] = shards.map((value) => (value).toJson()).toList();
     }
     return _json;
@@ skipping 22 matching lines @@
 
   SourceSplitShard.fromJson(core.Map _json) {
     if (_json.containsKey("derivationMode")) {
       derivationMode = _json["derivationMode"];
     }
     if (_json.containsKey("source")) {
       source = new Source.fromJson(_json["source"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (derivationMode != null) {
       _json["derivationMode"] = derivationMode;
     }
     if (source != null) {
       _json["source"] = (source).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 11 matching lines @@
 
   SplitInt64.fromJson(core.Map _json) {
     if (_json.containsKey("highBits")) {
       highBits = _json["highBits"];
     }
     if (_json.containsKey("lowBits")) {
       lowBits = _json["lowBits"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (highBits != null) {
       _json["highBits"] = highBits;
     }
     if (lowBits != null) {
       _json["lowBits"] = lowBits;
     }
     return _json;
   }
 }
 
@@ skipping 21 matching lines @@
       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();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (name != null) {
       _json["name"] = name;
     }
     if (originalTransformOrCollection != null) {
       _json["originalTransformOrCollection"] = originalTransformOrCollection;
     }
     if (sizeBytes != null) {
       _json["sizeBytes"] = sizeBytes;
     }
     if (userName != null) {
@@ skipping 14 matching lines @@
 
   StateFamilyConfig.fromJson(core.Map _json) {
     if (_json.containsKey("isRead")) {
       isRead = _json["isRead"];
     }
     if (_json.containsKey("stateFamily")) {
       stateFamily = _json["stateFamily"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (isRead != null) {
       _json["isRead"] = isRead;
     }
     if (stateFamily != null) {
       _json["stateFamily"] = stateFamily;
     }
     return _json;
   }
 }
 
@@ skipping 78 matching lines @@
       code = _json["code"];
     }
     if (_json.containsKey("details")) {
       details = _json["details"];
     }
     if (_json.containsKey("message")) {
       message = _json["message"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (code != null) {
       _json["code"] = code;
     }
     if (details != null) {
       _json["details"] = details;
     }
     if (message != null) {
       _json["message"] = message;
     }
     return _json;
@@ skipping 52 matching lines @@
       kind = _json["kind"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
     if (_json.containsKey("properties")) {
       properties = _json["properties"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (kind != null) {
       _json["kind"] = kind;
     }
     if (name != null) {
       _json["name"] = name;
     }
     if (properties != null) {
       _json["properties"] = properties;
     }
     return _json;
@@ skipping 27 matching lines @@
       pubsubLocation = new PubsubLocation.fromJson(_json["pubsubLocation"]);
     }
     if (_json.containsKey("sideInputLocation")) {
       sideInputLocation = new StreamingSideInputLocation.fromJson(_json["sideInputLocation"]);
     }
     if (_json.containsKey("streamingStageLocation")) {
       streamingStageLocation = new StreamingStageLocation.fromJson(_json["streamingStageLocation"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (customSourceLocation != null) {
       _json["customSourceLocation"] = (customSourceLocation).toJson();
     }
     if (pubsubLocation != null) {
       _json["pubsubLocation"] = (pubsubLocation).toJson();
     }
     if (sideInputLocation != null) {
       _json["sideInputLocation"] = (sideInputLocation).toJson();
     }
     if (streamingStageLocation != null) {
@@ skipping 24 matching lines @@
       instructions = _json["instructions"].map((value) => new ParallelInstruction.fromJson(value)).toList();
     }
     if (_json.containsKey("stageName")) {
       stageName = _json["stageName"];
     }
     if (_json.containsKey("systemName")) {
       systemName = _json["systemName"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (computationId != null) {
       _json["computationId"] = computationId;
     }
     if (instructions != null) {
       _json["instructions"] = instructions.map((value) => (value).toJson()).toList();
     }
     if (stageName != null) {
       _json["stageName"] = stageName;
     }
     if (systemName != null) {
@@ skipping 17 matching lines @@
 
   StreamingComputationRanges.fromJson(core.Map _json) {
     if (_json.containsKey("computationId")) {
       computationId = _json["computationId"];
     }
     if (_json.containsKey("rangeAssignments")) {
       rangeAssignments = _json["rangeAssignments"].map((value) => new KeyRangeDataDiskAssignment.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (computationId != null) {
       _json["computationId"] = computationId;
     }
     if (rangeAssignments != null) {
       _json["rangeAssignments"] = rangeAssignments.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
@@ skipping 25 matching lines @@
       computationRanges = _json["computationRanges"].map((value) => new StreamingComputationRanges.fromJson(value)).toList();
     }
     if (_json.containsKey("dataDisks")) {
       dataDisks = _json["dataDisks"].map((value) => new MountedDataDisk.fromJson(value)).toList();
     }
     if (_json.containsKey("taskType")) {
       taskType = _json["taskType"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (computationRanges != null) {
       _json["computationRanges"] = computationRanges.map((value) => (value).toJson()).toList();
     }
     if (dataDisks != null) {
       _json["dataDisks"] = dataDisks.map((value) => (value).toJson()).toList();
     }
     if (taskType != null) {
       _json["taskType"] = taskType;
     }
     return _json;
@@ skipping 31 matching lines @@
       userStepToStateFamilyNameMap = _json["userStepToStateFamilyNameMap"];
     }
     if (_json.containsKey("windmillServiceEndpoint")) {
       windmillServiceEndpoint = _json["windmillServiceEndpoint"];
     }
     if (_json.containsKey("windmillServicePort")) {
       windmillServicePort = _json["windmillServicePort"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (streamingComputationConfigs != null) {
       _json["streamingComputationConfigs"] = streamingComputationConfigs.map((value) => (value).toJson()).toList();
     }
     if (userStepToStateFamilyNameMap != null) {
       _json["userStepToStateFamilyNameMap"] = userStepToStateFamilyNameMap;
     }
     if (windmillServiceEndpoint != null) {
       _json["windmillServiceEndpoint"] = windmillServiceEndpoint;
     }
     if (windmillServicePort != null) {
@@ skipping 30 matching lines @@
       receiveWorkPort = _json["receiveWorkPort"];
     }
     if (_json.containsKey("streamingComputationTopology")) {
       streamingComputationTopology = new TopologyConfig.fromJson(_json["streamingComputationTopology"]);
     }
     if (_json.containsKey("workerHarnessPort")) {
       workerHarnessPort = _json["workerHarnessPort"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (drain != null) {
       _json["drain"] = drain;
     }
     if (receiveWorkPort != null) {
       _json["receiveWorkPort"] = receiveWorkPort;
     }
     if (streamingComputationTopology != null) {
       _json["streamingComputationTopology"] = (streamingComputationTopology).toJson();
     }
     if (workerHarnessPort != null) {
@@ skipping 16 matching lines @@
 
   StreamingSideInputLocation.fromJson(core.Map _json) {
     if (_json.containsKey("stateFamily")) {
       stateFamily = _json["stateFamily"];
     }
     if (_json.containsKey("tag")) {
       tag = _json["tag"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (stateFamily != null) {
       _json["stateFamily"] = stateFamily;
     }
     if (tag != null) {
       _json["tag"] = tag;
     }
     return _json;
   }
 }
 
 /**
  * Identifies the location of a streaming computation stage, for
  * stage-to-stage communication.
  */
 class StreamingStageLocation {
   /**
    * Identifies the particular stream within the streaming Dataflow
    * job.
    */
   core.String streamId;
 
   StreamingStageLocation();
 
   StreamingStageLocation.fromJson(core.Map _json) {
     if (_json.containsKey("streamId")) {
       streamId = _json["streamId"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (streamId != null) {
       _json["streamId"] = streamId;
     }
     return _json;
   }
 }
 
 /** A metric value representing a list of strings. */
 class StringList {
   /** Elements of the list. */
   core.List<core.String> elements;
 
   StringList();
 
   StringList.fromJson(core.Map _json) {
     if (_json.containsKey("elements")) {
       elements = _json["elements"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (elements != null) {
       _json["elements"] = elements;
     }
     return _json;
   }
 }
 
 /**
  * A rich message format, including a human readable string, a key for
  * identifying the message, and structured data associated with the message for
@@ skipping 17 matching lines @@
       messageKey = _json["messageKey"];
     }
     if (_json.containsKey("messageText")) {
       messageText = _json["messageText"];
     }
     if (_json.containsKey("parameters")) {
       parameters = _json["parameters"].map((value) => new Parameter.fromJson(value)).toList();
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (messageKey != null) {
       _json["messageKey"] = messageKey;
     }
     if (messageText != null) {
       _json["messageText"] = messageText;
     }
     if (parameters != null) {
       _json["parameters"] = parameters.map((value) => (value).toJson()).toList();
     }
     return _json;
@@ skipping 136 matching lines @@
       tempStoragePrefix = _json["tempStoragePrefix"];
     }
     if (_json.containsKey("vmId")) {
       vmId = _json["vmId"];
     }
     if (_json.containsKey("workflowFileName")) {
       workflowFileName = _json["workflowFileName"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (alsologtostderr != null) {
       _json["alsologtostderr"] = alsologtostderr;
     }
     if (baseTaskDir != null) {
       _json["baseTaskDir"] = baseTaskDir;
     }
     if (baseUrl != null) {
       _json["baseUrl"] = baseUrl;
     }
     if (commandlinesFileName != null) {
@@ skipping 43 matching lines @@
     }
     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;
-    }
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     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;
@@ skipping 29 matching lines @@
       forwardingKeyBits = _json["forwardingKeyBits"];
     }
     if (_json.containsKey("persistentStateVersion")) {
       persistentStateVersion = _json["persistentStateVersion"];
     }
     if (_json.containsKey("userStageToComputationNameMap")) {
       userStageToComputationNameMap = _json["userStageToComputationNameMap"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (computations != null) {
       _json["computations"] = computations.map((value) => (value).toJson()).toList();
     }
     if (dataDiskAssignments != null) {
       _json["dataDiskAssignments"] = dataDiskAssignments.map((value) => (value).toJson()).toList();
     }
     if (forwardingKeyBits != null) {
       _json["forwardingKeyBits"] = forwardingKeyBits;
     }
     if (persistentStateVersion != null) {
@@ skipping 51 matching lines @@
       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();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     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) {
@@ skipping 91 matching lines @@
       streamingComputationTask = new StreamingComputationTask.fromJson(_json["streamingComputationTask"]);
     }
     if (_json.containsKey("streamingConfigTask")) {
       streamingConfigTask = new StreamingConfigTask.fromJson(_json["streamingConfigTask"]);
     }
     if (_json.containsKey("streamingSetupTask")) {
       streamingSetupTask = new StreamingSetupTask.fromJson(_json["streamingSetupTask"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (configuration != null) {
       _json["configuration"] = configuration;
     }
     if (id != null) {
       _json["id"] = id;
     }
     if (initialReportIndex != null) {
       _json["initialReportIndex"] = initialReportIndex;
     }
     if (jobId != null) {
@@ skipping 100 matching lines @@
       splitRequest = new ApproximateSplitRequest.fromJson(_json["splitRequest"]);
     }
     if (_json.containsKey("suggestedStopPoint")) {
       suggestedStopPoint = new ApproximateProgress.fromJson(_json["suggestedStopPoint"]);
     }
     if (_json.containsKey("suggestedStopPosition")) {
       suggestedStopPosition = new Position.fromJson(_json["suggestedStopPosition"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (harnessData != null) {
       _json["harnessData"] = harnessData;
     }
     if (leaseExpireTime != null) {
       _json["leaseExpireTime"] = leaseExpireTime;
     }
     if (metricShortId != null) {
       _json["metricShortId"] = metricShortId.map((value) => (value).toJson()).toList();
     }
     if (nextReportIndex != null) {
@@ skipping 132 matching lines @@
       sourceOperationResponse = new SourceOperationResponse.fromJson(_json["sourceOperationResponse"]);
     }
     if (_json.containsKey("stopPosition")) {
       stopPosition = new Position.fromJson(_json["stopPosition"]);
     }
     if (_json.containsKey("workItemId")) {
       workItemId = _json["workItemId"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (completed != null) {
       _json["completed"] = completed;
     }
     if (counterUpdates != null) {
       _json["counterUpdates"] = counterUpdates.map((value) => (value).toJson()).toList();
     }
     if (dynamicSourceSplit != null) {
       _json["dynamicSourceSplit"] = (dynamicSourceSplit).toJson();
     }
     if (errors != null) {
@@ skipping 69 matching lines @@
       reportInterval = _json["reportInterval"];
     }
     if (_json.containsKey("vmIsHealthy")) {
       vmIsHealthy = _json["vmIsHealthy"];
     }
     if (_json.containsKey("vmStartupTime")) {
       vmStartupTime = _json["vmStartupTime"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (pods != null) {
       _json["pods"] = pods;
     }
     if (reportInterval != null) {
       _json["reportInterval"] = reportInterval;
     }
     if (vmIsHealthy != null) {
       _json["vmIsHealthy"] = vmIsHealthy;
     }
     if (vmStartupTime != null) {
@@ skipping 18 matching lines @@
   core.String reportInterval;
 
   WorkerHealthReportResponse();
 
   WorkerHealthReportResponse.fromJson(core.Map _json) {
     if (_json.containsKey("reportInterval")) {
       reportInterval = _json["reportInterval"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (reportInterval != null) {
       _json["reportInterval"] = reportInterval;
     }
     return _json;
   }
 }
 
 /** WorkerMessage provides information to the backend about a worker. */
 class WorkerMessage {
   /**
@@ skipping 31 matching lines @@
       workerHealthReport = new WorkerHealthReport.fromJson(_json["workerHealthReport"]);
     }
     if (_json.containsKey("workerMessageCode")) {
       workerMessageCode = new WorkerMessageCode.fromJson(_json["workerMessageCode"]);
     }
     if (_json.containsKey("workerMetrics")) {
       workerMetrics = new ResourceUtilizationReport.fromJson(_json["workerMetrics"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (labels != null) {
       _json["labels"] = labels;
     }
     if (time != null) {
       _json["time"] = time;
     }
     if (workerHealthReport != null) {
       _json["workerHealthReport"] = (workerHealthReport).toJson();
     }
     if (workerMessageCode != null) {
@@ skipping 62 matching lines @@
 
   WorkerMessageCode.fromJson(core.Map _json) {
     if (_json.containsKey("code")) {
       code = _json["code"];
     }
     if (_json.containsKey("parameters")) {
       parameters = _json["parameters"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (code != null) {
       _json["code"] = code;
     }
     if (parameters != null) {
       _json["parameters"] = parameters;
     }
     return _json;
   }
 }
 
@@ skipping 11 matching lines @@
 
   WorkerMessageResponse.fromJson(core.Map _json) {
     if (_json.containsKey("workerHealthReportResponse")) {
       workerHealthReportResponse = new WorkerHealthReportResponse.fromJson(_json["workerHealthReportResponse"]);
     }
     if (_json.containsKey("workerMetricsResponse")) {
       workerMetricsResponse = new ResourceUtilizationReportResponse.fromJson(_json["workerMetricsResponse"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (workerHealthReportResponse != null) {
       _json["workerHealthReportResponse"] = (workerHealthReportResponse).toJson();
     }
     if (workerMetricsResponse != null) {
       _json["workerMetricsResponse"] = (workerMetricsResponse).toJson();
     }
     return _json;
   }
 }
 
@@ skipping 200 matching lines @@
       teardownPolicy = _json["teardownPolicy"];
     }
     if (_json.containsKey("workerHarnessContainerImage")) {
       workerHarnessContainerImage = _json["workerHarnessContainerImage"];
     }
     if (_json.containsKey("zone")) {
       zone = _json["zone"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (autoscalingSettings != null) {
       _json["autoscalingSettings"] = (autoscalingSettings).toJson();
     }
     if (dataDisks != null) {
       _json["dataDisks"] = dataDisks.map((value) => (value).toJson()).toList();
     }
     if (defaultPackageSet != null) {
       _json["defaultPackageSet"] = defaultPackageSet;
     }
     if (diskSizeGb != null) {
@@ skipping 111 matching lines @@
       shuffleServicePath = _json["shuffleServicePath"];
     }
     if (_json.containsKey("tempStoragePrefix")) {
       tempStoragePrefix = _json["tempStoragePrefix"];
     }
     if (_json.containsKey("workerId")) {
       workerId = _json["workerId"];
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (baseUrl != null) {
       _json["baseUrl"] = baseUrl;
     }
     if (reportingEnabled != null) {
       _json["reportingEnabled"] = reportingEnabled;
     }
     if (servicePath != null) {
       _json["servicePath"] = servicePath;
     }
     if (shuffleServicePath != null) {
@@ skipping 23 matching lines @@
 
   WriteInstruction.fromJson(core.Map _json) {
     if (_json.containsKey("input")) {
       input = new InstructionInput.fromJson(_json["input"]);
     }
     if (_json.containsKey("sink")) {
       sink = new Sink.fromJson(_json["sink"]);
     }
   }
 
-  core.Map toJson() {
-    var _json = new core.Map();
+  core.Map<core.String, core.Object> toJson() {
+    final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }