Api-Roll 50: 2017-06-12

generated/googleapis/lib/dataproc/v1.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis.dataproc.v1;
 
 import 'dart:core' as core;
 import 'dart:async' as async;
 import 'dart:convert' as convert;
 
 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons;
 import 'package:http/http.dart' as http;
@@ skipping 260 matching lines @@
    * Lists all regions/{region}/clusters in a project.
    *
    * Request parameters:
    *
    * [projectId] - Required. The ID of the Google Cloud Platform project that
    * the cluster belongs to.
    *
    * [region] - Required. The Cloud Dataproc region in which to handle the
    * request.
    *
-   * [pageToken] - Optional. The standard List page token.
-   *
-   * [pageSize] - Optional. The standard List page size.
-   *
    * [filter] - Optional. A filter constraining the clusters to list. Filters
    * are case-sensitive and have the following syntax:field = value AND field =
    * value ...where field is one of status.state, clusterName, or labels.[KEY],
    * and [KEY] is a label key. value can be * to match all values. status.state
    * can be one of the following: ACTIVE, INACTIVE, CREATING, RUNNING, ERROR,
    * DELETING, or UPDATING. ACTIVE contains the CREATING, UPDATING, and RUNNING
    * states. INACTIVE contains the DELETING and ERROR states. clusterName is the
    * name of the cluster provided at creation time. Only the logical AND
    * operator is supported; space-separated items are treated as having an
    * implicit AND operator.Example filter:status.state = ACTIVE AND clusterName
    * = mycluster AND labels.env = staging AND labels.starred = *
    *
+   * [pageToken] - Optional. The standard List page token.
+   *
+   * [pageSize] - Optional. The standard List page size.
+   *
    * Completes with a [ListClustersResponse].
    *
    * 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<ListClustersResponse> list(core.String projectId, core.String region, {core.String pageToken, core.int pageSize, core.String filter}) {
+  async.Future<ListClustersResponse> list(core.String projectId, core.String region, {core.String filter, core.String pageToken, core.int pageSize}) {
     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 (region == null) {
       throw new core.ArgumentError("Parameter region is required.");
     }
+    if (filter != null) {
+      _queryParams["filter"] = [filter];
+    }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
-    if (filter != null) {
-      _queryParams["filter"] = [filter];
-    }
 
     _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regions/' + commons.Escaper.ecapeVariable('$region') + '/clusters';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 600 matching lines @@
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Operation.fromJson(data));
   }
 
   /**
    * Lists operations that match the specified filter in the request. If the
    * server doesn't support this method, it returns UNIMPLEMENTED.NOTE: the name
-   * binding below allows API services to override the binding to use different
-   * resource name schemes, such as users / * /operations.
+   * binding allows API services to override the binding to use different
+   * resource name schemes, such as users / * /operations. To override the
+   * binding, API services can add a binding such as "/v1/{name=users / *
+   * }/operations" to their service configuration. For backwards compatibility,
+   * the default name includes the operations collection id, however overriding
+   * users must ensure the name binding is the parent resource, without the
+   * operations collection id.
    *
    * Request parameters:
    *
-   * [name] - The name of the operation collection.
+   * [name] - The name of the operation's parent resource.
    * Value must have pattern "^projects/[^/]+/regions/[^/]+/operations$".
    *
+   * [pageToken] - The standard list page token.
+   *
    * [pageSize] - The standard list page size.
    *
    * [filter] - The standard list filter.
    *
-   * [pageToken] - The standard list page token.
-   *
    * Completes with a [ListOperationsResponse].
    *
    * 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<ListOperationsResponse> list(core.String name, {core.int pageSize, core.String filter, core.String pageToken}) {
+  async.Future<ListOperationsResponse> list(core.String name, {core.String pageToken, core.int pageSize, 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 (name == null) {
       throw new core.ArgumentError("Parameter name is required.");
     }
+    if (pageToken != null) {
+      _queryParams["pageToken"] = [pageToken];
+    }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (filter != null) {
       _queryParams["filter"] = [filter];
     }
-    if (pageToken != null) {
-      _queryParams["pageToken"] = [pageToken];
-    }
 
     _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name');
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 24 matching lines @@
 
   AcceleratorConfig.fromJson(core.Map _json) {
     if (_json.containsKey("acceleratorCount")) {
       acceleratorCount = _json["acceleratorCount"];
     }
     if (_json.containsKey("acceleratorTypeUri")) {
       acceleratorTypeUri = _json["acceleratorTypeUri"];
     }
   }
 
-  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 (acceleratorCount != null) {
       _json["acceleratorCount"] = acceleratorCount;
     }
     if (acceleratorTypeUri != null) {
       _json["acceleratorTypeUri"] = acceleratorTypeUri;
     }
     return _json;
   }
 }
 
 /** A request to cancel a job. */
 class CancelJobRequest {
 
   CancelJobRequest();
 
   CancelJobRequest.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;
   }
 }
 
 /**
  * Describes the identifying information, config, and status of a cluster of
  * Google Compute Engine instances.
  */
 class Cluster {
   /**
@@ skipping 57 matching lines @@
       projectId = _json["projectId"];
     }
     if (_json.containsKey("status")) {
       status = new ClusterStatus.fromJson(_json["status"]);
     }
     if (_json.containsKey("statusHistory")) {
       statusHistory = _json["statusHistory"].map((value) => new ClusterStatus.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 (clusterName != null) {
       _json["clusterName"] = clusterName;
     }
     if (clusterUuid != null) {
       _json["clusterUuid"] = clusterUuid;
     }
     if (config != null) {
       _json["config"] = (config).toJson();
     }
     if (labels != null) {
@@ skipping 82 matching lines @@
       secondaryWorkerConfig = new InstanceGroupConfig.fromJson(_json["secondaryWorkerConfig"]);
     }
     if (_json.containsKey("softwareConfig")) {
       softwareConfig = new SoftwareConfig.fromJson(_json["softwareConfig"]);
     }
     if (_json.containsKey("workerConfig")) {
       workerConfig = new InstanceGroupConfig.fromJson(_json["workerConfig"]);
     }
   }
 
-  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 (configBucket != null) {
       _json["configBucket"] = configBucket;
     }
     if (gceClusterConfig != null) {
       _json["gceClusterConfig"] = (gceClusterConfig).toJson();
     }
     if (initializationActions != null) {
       _json["initializationActions"] = initializationActions.map((value) => (value).toJson()).toList();
     }
     if (masterConfig != null) {
@@ skipping 27 matching lines @@
 
   ClusterMetrics.fromJson(core.Map _json) {
     if (_json.containsKey("hdfsMetrics")) {
       hdfsMetrics = _json["hdfsMetrics"];
     }
     if (_json.containsKey("yarnMetrics")) {
       yarnMetrics = _json["yarnMetrics"];
     }
   }
 
-  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 (hdfsMetrics != null) {
       _json["hdfsMetrics"] = hdfsMetrics;
     }
     if (yarnMetrics != null) {
       _json["yarnMetrics"] = yarnMetrics;
     }
     return _json;
   }
 }
 
@@ skipping 38 matching lines @@
       status = new ClusterOperationStatus.fromJson(_json["status"]);
     }
     if (_json.containsKey("statusHistory")) {
       statusHistory = _json["statusHistory"].map((value) => new ClusterOperationStatus.fromJson(value)).toList();
     }
     if (_json.containsKey("warnings")) {
       warnings = _json["warnings"];
     }
   }
 
-  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 (clusterName != null) {
       _json["clusterName"] = clusterName;
     }
     if (clusterUuid != null) {
       _json["clusterUuid"] = clusterUuid;
     }
     if (description != null) {
       _json["description"] = description;
     }
     if (labels != null) {
@@ skipping 43 matching lines @@
       innerState = _json["innerState"];
     }
     if (_json.containsKey("state")) {
       state = _json["state"];
     }
     if (_json.containsKey("stateStartTime")) {
       stateStartTime = _json["stateStartTime"];
     }
   }
 
-  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 (details != null) {
       _json["details"] = details;
     }
     if (innerState != null) {
       _json["innerState"] = innerState;
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (stateStartTime != null) {
@@ skipping 46 matching lines @@
       state = _json["state"];
     }
     if (_json.containsKey("stateStartTime")) {
       stateStartTime = _json["stateStartTime"];
     }
     if (_json.containsKey("substate")) {
       substate = _json["substate"];
     }
   }
 
-  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 (detail != null) {
       _json["detail"] = detail;
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (stateStartTime != null) {
       _json["stateStartTime"] = stateStartTime;
     }
     if (substate != null) {
       _json["substate"] = substate;
     }
     return _json;
   }
 }
 
-/** The location where output from diagnostic command can be found. */
-class DiagnoseClusterOutputLocation {
-  /**
-   * Output-only The Google Cloud Storage URI of the diagnostic output. This
-   * will be a plain text file with summary of collected diagnostics.
-   */
-  core.String outputUri;
-
-  DiagnoseClusterOutputLocation();
-
-  DiagnoseClusterOutputLocation.fromJson(core.Map _json) {
-    if (_json.containsKey("outputUri")) {
-      outputUri = _json["outputUri"];
-    }
-  }
-
-  core.Map toJson() {
-    var _json = new core.Map();
-    if (outputUri != null) {
-      _json["outputUri"] = outputUri;
-    }
-    return _json;
-  }
-}
-
 /** A request to collect cluster diagnostic information. */
 class DiagnoseClusterRequest {
 
   DiagnoseClusterRequest();
 
   DiagnoseClusterRequest.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 location of diagnostic output. */
 class DiagnoseClusterResults {
   /**
    * Output-only. The Google Cloud Storage URI of the diagnostic output. The
    * output report is a plain text file with a summary of collected diagnostics.
    */
   core.String outputUri;
 
   DiagnoseClusterResults();
 
   DiagnoseClusterResults.fromJson(core.Map _json) {
     if (_json.containsKey("outputUri")) {
       outputUri = _json["outputUri"];
     }
   }
 
-  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 (outputUri != null) {
       _json["outputUri"] = outputUri;
     }
     return _json;
   }
 }
 
 /** Specifies the config of disk options for a group of VM instances. */
 class DiskConfig {
   /** Optional. Size in GB of the boot disk (default is 500GB). */
@@ skipping 11 matching lines @@
 
   DiskConfig.fromJson(core.Map _json) {
     if (_json.containsKey("bootDiskSizeGb")) {
       bootDiskSizeGb = _json["bootDiskSizeGb"];
     }
     if (_json.containsKey("numLocalSsds")) {
       numLocalSsds = _json["numLocalSsds"];
     }
   }
 
-  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 (bootDiskSizeGb != null) {
       _json["bootDiskSizeGb"] = bootDiskSizeGb;
     }
     if (numLocalSsds != null) {
       _json["numLocalSsds"] = numLocalSsds;
     }
     return _json;
   }
 }
 
 /**
  * A generic empty message that you can re-use to avoid defining duplicated
  * empty messages in your APIs. A typical example is to use it as the request or
  * the response type of an API method. For instance:
  * service Foo {
  *   rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty);
  * }
  * The JSON representation for Empty is empty JSON object {}.
  */
 class Empty {
 
   Empty();
 
   Empty.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;
   }
 }
 
 /**
  * Common config settings for resources of Google Compute Engine cluster
  * instances, applicable to all instances in the cluster.
  */
 class GceClusterConfig {
   /**
@@ skipping 85 matching lines @@
       subnetworkUri = _json["subnetworkUri"];
     }
     if (_json.containsKey("tags")) {
       tags = _json["tags"];
     }
     if (_json.containsKey("zoneUri")) {
       zoneUri = _json["zoneUri"];
     }
   }
 
-  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 (internalIpOnly != null) {
       _json["internalIpOnly"] = internalIpOnly;
     }
     if (metadata != null) {
       _json["metadata"] = metadata;
     }
     if (networkUri != null) {
       _json["networkUri"] = networkUri;
     }
     if (serviceAccount != null) {
@@ skipping 89 matching lines @@
       mainClass = _json["mainClass"];
     }
     if (_json.containsKey("mainJarFileUri")) {
       mainJarFileUri = _json["mainJarFileUri"];
     }
     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 (archiveUris != null) {
       _json["archiveUris"] = archiveUris;
     }
     if (args != null) {
       _json["args"] = args;
     }
     if (fileUris != null) {
       _json["fileUris"] = fileUris;
     }
     if (jarFileUris != null) {
@@ skipping 64 matching lines @@
       queryFileUri = _json["queryFileUri"];
     }
     if (_json.containsKey("queryList")) {
       queryList = new QueryList.fromJson(_json["queryList"]);
     }
     if (_json.containsKey("scriptVariables")) {
       scriptVariables = _json["scriptVariables"];
     }
   }
 
-  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 (continueOnFailure != null) {
       _json["continueOnFailure"] = continueOnFailure;
     }
     if (jarFileUris != null) {
       _json["jarFileUris"] = jarFileUris;
     }
     if (properties != null) {
       _json["properties"] = properties;
     }
     if (queryFileUri != null) {
@@ skipping 77 matching lines @@
       machineTypeUri = _json["machineTypeUri"];
     }
     if (_json.containsKey("managedGroupConfig")) {
       managedGroupConfig = new ManagedGroupConfig.fromJson(_json["managedGroupConfig"]);
     }
     if (_json.containsKey("numInstances")) {
       numInstances = _json["numInstances"];
     }
   }
 
-  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 (accelerators != null) {
       _json["accelerators"] = accelerators.map((value) => (value).toJson()).toList();
     }
     if (diskConfig != null) {
       _json["diskConfig"] = (diskConfig).toJson();
     }
     if (imageUri != null) {
       _json["imageUri"] = imageUri;
     }
     if (instanceNames != null) {
@@ skipping 120 matching lines @@
       status = new JobStatus.fromJson(_json["status"]);
     }
     if (_json.containsKey("statusHistory")) {
       statusHistory = _json["statusHistory"].map((value) => new JobStatus.fromJson(value)).toList();
     }
     if (_json.containsKey("yarnApplications")) {
       yarnApplications = _json["yarnApplications"].map((value) => new YarnApplication.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 (driverControlFilesUri != null) {
       _json["driverControlFilesUri"] = driverControlFilesUri;
     }
     if (driverOutputResourceUri != null) {
       _json["driverOutputResourceUri"] = driverOutputResourceUri;
     }
     if (hadoopJob != null) {
       _json["hadoopJob"] = (hadoopJob).toJson();
     }
     if (hiveJob != null) {
@@ skipping 50 matching lines @@
 
   JobPlacement.fromJson(core.Map _json) {
     if (_json.containsKey("clusterName")) {
       clusterName = _json["clusterName"];
     }
     if (_json.containsKey("clusterUuid")) {
       clusterUuid = _json["clusterUuid"];
     }
   }
 
-  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 (clusterName != null) {
       _json["clusterName"] = clusterName;
     }
     if (clusterUuid != null) {
       _json["clusterUuid"] = clusterUuid;
     }
     return _json;
   }
 }
 
@@ skipping 17 matching lines @@
 
   JobReference.fromJson(core.Map _json) {
     if (_json.containsKey("jobId")) {
       jobId = _json["jobId"];
     }
     if (_json.containsKey("projectId")) {
       projectId = _json["projectId"];
     }
   }
 
-  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 (jobId != null) {
       _json["jobId"] = jobId;
     }
     if (projectId != null) {
       _json["projectId"] = projectId;
     }
     return _json;
   }
 }
 
@@ skipping 11 matching lines @@
   core.int maxFailuresPerHour;
 
   JobScheduling();
 
   JobScheduling.fromJson(core.Map _json) {
     if (_json.containsKey("maxFailuresPerHour")) {
       maxFailuresPerHour = _json["maxFailuresPerHour"];
     }
   }
 
-  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 (maxFailuresPerHour != null) {
       _json["maxFailuresPerHour"] = maxFailuresPerHour;
     }
     return _json;
   }
 }
 
 /** Cloud Dataproc job status. */
 class JobStatus {
   /**
@@ skipping 48 matching lines @@
       state = _json["state"];
     }
     if (_json.containsKey("stateStartTime")) {
       stateStartTime = _json["stateStartTime"];
     }
     if (_json.containsKey("substate")) {
       substate = _json["substate"];
     }
   }
 
-  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 (details != null) {
       _json["details"] = details;
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (stateStartTime != null) {
       _json["stateStartTime"] = stateStartTime;
     }
     if (substate != null) {
@@ skipping 18 matching lines @@
 
   ListClustersResponse.fromJson(core.Map _json) {
     if (_json.containsKey("clusters")) {
       clusters = _json["clusters"].map((value) => new Cluster.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 (clusters != null) {
       _json["clusters"] = clusters.map((value) => (value).toJson()).toList();
     }
     if (nextPageToken != null) {
       _json["nextPageToken"] = nextPageToken;
     }
     return _json;
   }
 }
 
@@ skipping 12 matching lines @@
 
   ListJobsResponse.fromJson(core.Map _json) {
     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 (jobs != null) {
       _json["jobs"] = jobs.map((value) => (value).toJson()).toList();
     }
     if (nextPageToken != null) {
       _json["nextPageToken"] = nextPageToken;
     }
     return _json;
   }
 }
 
 /** The response message for Operations.ListOperations. */
 class ListOperationsResponse {
   /** The standard List next-page token. */
   core.String nextPageToken;
   /** A list of operations that matches the specified filter in the request. */
   core.List<Operation> operations;
 
   ListOperationsResponse();
 
   ListOperationsResponse.fromJson(core.Map _json) {
     if (_json.containsKey("nextPageToken")) {
       nextPageToken = _json["nextPageToken"];
     }
     if (_json.containsKey("operations")) {
       operations = _json["operations"].map((value) => new Operation.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 (nextPageToken != null) {
       _json["nextPageToken"] = nextPageToken;
     }
     if (operations != null) {
       _json["operations"] = operations.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /** The runtime logging config of the job. */
 class LoggingConfig {
   /**
    * The per-package log levels for the driver. This may include "root" package
    * name to configure rootLogger. Examples:  'com.google = FATAL', 'root =
    * INFO', 'org.apache = DEBUG'
    */
   core.Map<core.String, core.String> driverLogLevels;
 
   LoggingConfig();
 
   LoggingConfig.fromJson(core.Map _json) {
     if (_json.containsKey("driverLogLevels")) {
       driverLogLevels = _json["driverLogLevels"];
     }
   }
 
-  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 (driverLogLevels != null) {
       _json["driverLogLevels"] = driverLogLevels;
     }
     return _json;
   }
 }
 
 /** Specifies the resources used to actively manage an instance group. */
 class ManagedGroupConfig {
   /** Output-only. The name of the Instance Group Manager for this group. */
   core.String instanceGroupManagerName;
   /**
    * Output-only. The name of the Instance Template used for the Managed
    * Instance Group.
    */
   core.String instanceTemplateName;
 
   ManagedGroupConfig();
 
   ManagedGroupConfig.fromJson(core.Map _json) {
     if (_json.containsKey("instanceGroupManagerName")) {
       instanceGroupManagerName = _json["instanceGroupManagerName"];
     }
     if (_json.containsKey("instanceTemplateName")) {
       instanceTemplateName = _json["instanceTemplateName"];
     }
   }
 
-  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 (instanceGroupManagerName != null) {
       _json["instanceGroupManagerName"] = instanceGroupManagerName;
     }
     if (instanceTemplateName != null) {
       _json["instanceTemplateName"] = instanceTemplateName;
     }
     return _json;
   }
 }
 
@@ skipping 16 matching lines @@
 
   NodeInitializationAction.fromJson(core.Map _json) {
     if (_json.containsKey("executableFile")) {
       executableFile = _json["executableFile"];
     }
     if (_json.containsKey("executionTimeout")) {
       executionTimeout = _json["executionTimeout"];
     }
   }
 
-  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 (executableFile != null) {
       _json["executableFile"] = executableFile;
     }
     if (executionTimeout != null) {
       _json["executionTimeout"] = executionTimeout;
     }
     return _json;
   }
 }
 
@@ skipping 53 matching lines @@
       metadata = _json["metadata"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
     if (_json.containsKey("response")) {
       response = _json["response"];
     }
   }
 
-  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 (done != null) {
       _json["done"] = done;
     }
     if (error != null) {
       _json["error"] = (error).toJson();
     }
     if (metadata != null) {
       _json["metadata"] = metadata;
     }
     if (name != null) {
       _json["name"] = name;
     }
     if (response != null) {
       _json["response"] = response;
     }
     return _json;
   }
 }
 
-/** Metadata describing the operation. */
-class OperationMetadata {
-  /** Name of the cluster for the operation. */
-  core.String clusterName;
-  /** Cluster UUId for the operation. */
-  core.String clusterUuid;
-  /** Output-only Short description of operation. */
-  core.String description;
-  /** A message containing any operation metadata details. */
-  core.String details;
-  /** The time that the operation completed. */
-  core.String endTime;
-  /** A message containing the detailed operation state. */
-  core.String innerState;
-  /** The time that the operation was requested. */
-  core.String insertTime;
-  /** Output-only The operation type. */
-  core.String operationType;
-  /** The time that the operation was started by the server. */
-  core.String startTime;
-  /**
-   * A message containing the operation state.
-   * Possible string values are:
-   * - "UNKNOWN" : Unused.
-   * - "PENDING" : The operation has been created.
-   * - "RUNNING" : The operation is currently running.
-   * - "DONE" : The operation is done, either cancelled or completed.
-   */
-  core.String state;
-  /** Output-only Current operation status. */
-  OperationStatus status;
-  /** Output-only Previous operation status. */
-  core.List<OperationStatus> statusHistory;
-  /** Output-only Errors encountered during operation execution. */
-  core.List<core.String> warnings;
-
-  OperationMetadata();
-
-  OperationMetadata.fromJson(core.Map _json) {
-    if (_json.containsKey("clusterName")) {
-      clusterName = _json["clusterName"];
-    }
-    if (_json.containsKey("clusterUuid")) {
-      clusterUuid = _json["clusterUuid"];
-    }
-    if (_json.containsKey("description")) {
-      description = _json["description"];
-    }
-    if (_json.containsKey("details")) {
-      details = _json["details"];
-    }
-    if (_json.containsKey("endTime")) {
-      endTime = _json["endTime"];
-    }
-    if (_json.containsKey("innerState")) {
-      innerState = _json["innerState"];
-    }
-    if (_json.containsKey("insertTime")) {
-      insertTime = _json["insertTime"];
-    }
-    if (_json.containsKey("operationType")) {
-      operationType = _json["operationType"];
-    }
-    if (_json.containsKey("startTime")) {
-      startTime = _json["startTime"];
-    }
-    if (_json.containsKey("state")) {
-      state = _json["state"];
-    }
-    if (_json.containsKey("status")) {
-      status = new OperationStatus.fromJson(_json["status"]);
-    }
-    if (_json.containsKey("statusHistory")) {
-      statusHistory = _json["statusHistory"].map((value) => new OperationStatus.fromJson(value)).toList();
-    }
-    if (_json.containsKey("warnings")) {
-      warnings = _json["warnings"];
-    }
-  }
-
-  core.Map toJson() {
-    var _json = new core.Map();
-    if (clusterName != null) {
-      _json["clusterName"] = clusterName;
-    }
-    if (clusterUuid != null) {
-      _json["clusterUuid"] = clusterUuid;
-    }
-    if (description != null) {
-      _json["description"] = description;
-    }
-    if (details != null) {
-      _json["details"] = details;
-    }
-    if (endTime != null) {
-      _json["endTime"] = endTime;
-    }
-    if (innerState != null) {
-      _json["innerState"] = innerState;
-    }
-    if (insertTime != null) {
-      _json["insertTime"] = insertTime;
-    }
-    if (operationType != null) {
-      _json["operationType"] = operationType;
-    }
-    if (startTime != null) {
-      _json["startTime"] = startTime;
-    }
-    if (state != null) {
-      _json["state"] = state;
-    }
-    if (status != null) {
-      _json["status"] = (status).toJson();
-    }
-    if (statusHistory != null) {
-      _json["statusHistory"] = statusHistory.map((value) => (value).toJson()).toList();
-    }
-    if (warnings != null) {
-      _json["warnings"] = warnings;
-    }
-    return _json;
-  }
-}
-
-/** The status of the operation. */
-class OperationStatus {
-  /** A message containing any operation metadata details. */
-  core.String details;
-  /** A message containing the detailed operation state. */
-  core.String innerState;
-  /**
-   * A message containing the operation state.
-   * Possible string values are:
-   * - "UNKNOWN" : Unused.
-   * - "PENDING" : The operation has been created.
-   * - "RUNNING" : The operation is running.
-   * - "DONE" : The operation is done; either cancelled or completed.
-   */
-  core.String state;
-  /** The time this state was entered. */
-  core.String stateStartTime;
-
-  OperationStatus();
-
-  OperationStatus.fromJson(core.Map _json) {
-    if (_json.containsKey("details")) {
-      details = _json["details"];
-    }
-    if (_json.containsKey("innerState")) {
-      innerState = _json["innerState"];
-    }
-    if (_json.containsKey("state")) {
-      state = _json["state"];
-    }
-    if (_json.containsKey("stateStartTime")) {
-      stateStartTime = _json["stateStartTime"];
-    }
-  }
-
-  core.Map toJson() {
-    var _json = new core.Map();
-    if (details != null) {
-      _json["details"] = details;
-    }
-    if (innerState != null) {
-      _json["innerState"] = innerState;
-    }
-    if (state != null) {
-      _json["state"] = state;
-    }
-    if (stateStartTime != null) {
-      _json["stateStartTime"] = stateStartTime;
-    }
-    return _json;
-  }
-}
-
 /**
  * A Cloud Dataproc job for running Apache Pig (https://pig.apache.org/) queries
  * on YARN.
  */
 class PigJob {
   /**
    * Optional. Whether to continue executing queries if a query fails. The
    * default value is false. Setting to true can be useful when executing
    * independent parallel queries.
    */
@@ skipping 41 matching lines @@
       queryFileUri = _json["queryFileUri"];
     }
     if (_json.containsKey("queryList")) {
       queryList = new QueryList.fromJson(_json["queryList"]);
     }
     if (_json.containsKey("scriptVariables")) {
       scriptVariables = _json["scriptVariables"];
     }
   }
 
-  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 (continueOnFailure != null) {
       _json["continueOnFailure"] = continueOnFailure;
     }
     if (jarFileUris != null) {
       _json["jarFileUris"] = jarFileUris;
     }
     if (loggingConfig != null) {
       _json["loggingConfig"] = (loggingConfig).toJson();
     }
     if (properties != null) {
@@ skipping 81 matching lines @@
       mainPythonFileUri = _json["mainPythonFileUri"];
     }
     if (_json.containsKey("properties")) {
       properties = _json["properties"];
     }
     if (_json.containsKey("pythonFileUris")) {
       pythonFileUris = _json["pythonFileUris"];
     }
   }
 
-  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 (archiveUris != null) {
       _json["archiveUris"] = archiveUris;
     }
     if (args != null) {
       _json["args"] = args;
     }
     if (fileUris != null) {
       _json["fileUris"] = fileUris;
     }
     if (jarFileUris != null) {
@@ skipping 35 matching lines @@
   core.List<core.String> queries;
 
   QueryList();
 
   QueryList.fromJson(core.Map _json) {
     if (_json.containsKey("queries")) {
       queries = _json["queries"];
     }
   }
 
-  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 (queries != null) {
       _json["queries"] = queries;
     }
     return _json;
   }
 }
 
 /** Specifies the selection and config of software inside the cluster. */
 class SoftwareConfig {
   /**
@@ skipping 22 matching lines @@
 
   SoftwareConfig.fromJson(core.Map _json) {
     if (_json.containsKey("imageVersion")) {
       imageVersion = _json["imageVersion"];
     }
     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 (imageVersion != null) {
       _json["imageVersion"] = imageVersion;
     }
     if (properties != null) {
       _json["properties"] = properties;
     }
     return _json;
   }
 }
 
@@ skipping 63 matching lines @@
       mainClass = _json["mainClass"];
     }
     if (_json.containsKey("mainJarFileUri")) {
       mainJarFileUri = _json["mainJarFileUri"];
     }
     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 (archiveUris != null) {
       _json["archiveUris"] = archiveUris;
     }
     if (args != null) {
       _json["args"] = args;
     }
     if (fileUris != null) {
       _json["fileUris"] = fileUris;
     }
     if (jarFileUris != null) {
@@ skipping 56 matching lines @@
       queryFileUri = _json["queryFileUri"];
     }
     if (_json.containsKey("queryList")) {
       queryList = new QueryList.fromJson(_json["queryList"]);
     }
     if (_json.containsKey("scriptVariables")) {
       scriptVariables = _json["scriptVariables"];
     }
   }
 
-  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 (jarFileUris != null) {
       _json["jarFileUris"] = jarFileUris;
     }
     if (loggingConfig != null) {
       _json["loggingConfig"] = (loggingConfig).toJson();
     }
     if (properties != null) {
       _json["properties"] = properties;
     }
     if (queryFileUri != null) {
@@ skipping 70 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;
   }
 }
 
 /** A request to submit a job. */
 class SubmitJobRequest {
   /** Required. The job resource. */
   Job job;
 
   SubmitJobRequest();
 
   SubmitJobRequest.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;
   }
 }
 
 /**
  * A YARN application created by a job. Application information is a subset of
  * <code>org.apache.hadoop.yarn.proto.YarnProtos.ApplicationReportProto</code>.Beta
@@ skipping 37 matching lines @@
       progress = _json["progress"];
     }
     if (_json.containsKey("state")) {
       state = _json["state"];
     }
     if (_json.containsKey("trackingUrl")) {
       trackingUrl = _json["trackingUrl"];
     }
   }
 
-  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 (progress != null) {
       _json["progress"] = progress;
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (trackingUrl != null) {
       _json["trackingUrl"] = trackingUrl;
     }
     return _json;
   }
 }