Index: generated/googleapis_beta/lib/dataproc/v1beta1.dart |
diff --git a/generated/googleapis_beta/lib/dataproc/v1beta1.dart b/generated/googleapis_beta/lib/dataproc/v1beta1.dart |
index c4b2e0e0bbcbafb5e88026c806552078227c3a7e..62afbc6671b82b5931fcb1e24bd0d154cb5de361 100644 |
--- a/generated/googleapis_beta/lib/dataproc/v1beta1.dart |
+++ b/generated/googleapis_beta/lib/dataproc/v1beta1.dart |
@@ -733,14 +733,6 @@ class ProjectsJobsResourceApi { |
* [projectId] - Required The ID of the Google Cloud Platform project that the |
* job belongs to. |
* |
- * [pageToken] - Optional The page token, returned by a previous call, to |
- * request the next page of results. |
- * |
- * [pageSize] - Optional The number of results to return in each response. |
- * |
- * [clusterName] - Optional If set, the returned jobs list includes only jobs |
- * that were submitted to the named cluster. |
- * |
* [filter] - Optional A filter constraining which jobs to list. Valid filters |
* contain job state and label terms such as: labels.key1 = val1 AND |
* (labels.k2 = val2 OR labels.k3 = val3) |
@@ -752,6 +744,14 @@ class ProjectsJobsResourceApi { |
* - "ACTIVE" : A ACTIVE. |
* - "NON_ACTIVE" : A NON_ACTIVE. |
* |
+ * [pageToken] - Optional The page token, returned by a previous call, to |
+ * request the next page of results. |
+ * |
+ * [pageSize] - Optional The number of results to return in each response. |
+ * |
+ * [clusterName] - Optional If set, the returned jobs list includes only jobs |
+ * that were submitted to the named cluster. |
+ * |
* Completes with a [ListJobsResponse]. |
* |
* Completes with a [commons.ApiRequestError] if the API endpoint returned an |
@@ -760,7 +760,7 @@ class ProjectsJobsResourceApi { |
* 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 pageToken, core.int pageSize, core.String clusterName, core.String filter, core.String jobStateMatcher}) { |
+ async.Future<ListJobsResponse> list(core.String projectId, {core.String filter, core.String jobStateMatcher, core.String pageToken, core.int pageSize, core.String clusterName}) { |
var _url = null; |
var _queryParams = new core.Map(); |
var _uploadMedia = null; |
@@ -771,6 +771,12 @@ class ProjectsJobsResourceApi { |
if (projectId == null) { |
throw new core.ArgumentError("Parameter projectId is required."); |
} |
+ if (filter != null) { |
+ _queryParams["filter"] = [filter]; |
+ } |
+ if (jobStateMatcher != null) { |
+ _queryParams["jobStateMatcher"] = [jobStateMatcher]; |
+ } |
if (pageToken != null) { |
_queryParams["pageToken"] = [pageToken]; |
} |
@@ -780,12 +786,6 @@ class ProjectsJobsResourceApi { |
if (clusterName != null) { |
_queryParams["clusterName"] = [clusterName]; |
} |
- if (filter != null) { |
- _queryParams["filter"] = [filter]; |
- } |
- if (jobStateMatcher != null) { |
- _queryParams["jobStateMatcher"] = [jobStateMatcher]; |
- } |
_url = 'v1beta1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs'; |
@@ -908,6 +908,45 @@ class ProjectsJobsResourceApi { |
+/** |
+ * Specifies the type and number of accelerator cards attached to the instances |
+ * of an instance group (see GPUs on Compute Engine). |
+ */ |
+class AcceleratorConfiguration { |
+ /** |
+ * The number of the accelerator cards of this type exposed to this instance. |
+ */ |
+ core.int acceleratorCount; |
+ /** |
+ * Full or partial URI of the accelerator type resource to expose to this |
+ * instance. See Google Compute Engine AcceleratorTypes( |
+ * /compute/docs/reference/beta/acceleratorTypes) |
+ */ |
+ core.String acceleratorTypeUri; |
+ |
+ AcceleratorConfiguration(); |
+ |
+ AcceleratorConfiguration.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(); |
+ if (acceleratorCount != null) { |
+ _json["acceleratorCount"] = acceleratorCount; |
+ } |
+ if (acceleratorTypeUri != null) { |
+ _json["acceleratorTypeUri"] = acceleratorTypeUri; |
+ } |
+ return _json; |
+ } |
+} |
+ |
/** A request to cancel a job. */ |
class CancelJobRequest { |
@@ -1346,11 +1385,11 @@ class ClusterStatus { |
} |
} |
-/** The location where output from diagnostic command can be found. */ |
+/** The location of diagnostic output. */ |
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. |
+ * Output-only The Google Cloud Storage URI of the diagnostic output. This is |
+ * a plain text file with a summary of collected diagnostics. |
*/ |
core.String outputUri; |
@@ -1780,6 +1819,11 @@ class HiveJob { |
* group, such as a master or worker group. |
*/ |
class InstanceGroupConfiguration { |
+ /** |
+ * Optional The Google Compute Engine accelerator configuration for these |
+ * instances. |
+ */ |
+ core.List<AcceleratorConfiguration> accelerators; |
/** Disk option configuration settings. */ |
DiskConfiguration diskConfiguration; |
/** |
@@ -1815,6 +1859,9 @@ class InstanceGroupConfiguration { |
InstanceGroupConfiguration(); |
InstanceGroupConfiguration.fromJson(core.Map _json) { |
+ if (_json.containsKey("accelerators")) { |
+ accelerators = _json["accelerators"].map((value) => new AcceleratorConfiguration.fromJson(value)).toList(); |
+ } |
if (_json.containsKey("diskConfiguration")) { |
diskConfiguration = new DiskConfiguration.fromJson(_json["diskConfiguration"]); |
} |
@@ -1840,6 +1887,9 @@ class InstanceGroupConfiguration { |
core.Map toJson() { |
var _json = new core.Map(); |
+ if (accelerators != null) { |
+ _json["accelerators"] = accelerators.map((value) => (value).toJson()).toList(); |
+ } |
if (diskConfiguration != null) { |
_json["diskConfiguration"] = (diskConfiguration).toJson(); |
} |
@@ -2098,7 +2148,7 @@ class JobReference { |
* generated by the server upon job submission or provided by the user as a |
* means to perform retries without creating duplicate jobs. The ID must |
* contain only letters (a-z, A-Z), numbers (0-9), underscores (_), or hyphens |
- * (-). The maximum length is 512 characters. |
+ * (-). The maximum length is 100 characters. |
*/ |
core.String jobId; |
/** |
@@ -2501,27 +2551,8 @@ class OperationMetadata { |
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. */ |
@@ -2541,27 +2572,9 @@ class OperationMetadata { |
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"]); |
} |
@@ -2584,27 +2597,9 @@ class OperationMetadata { |
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(); |
} |