| Index: generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| diff --git a/generated/googleapis_beta/lib/dataflow/v1b3.dart b/generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| index f102fbbb62f879389b2151b3e402218d7495dbf2..12b014c98b5de8ef4828b88649da4a1b061e3eb1 100644
|
| --- a/generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| +++ b/generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| @@ -172,8 +172,6 @@ class ProjectsJobsResourceApi {
|
| *
|
| * [jobId] - The job ID.
|
| *
|
| - * [location] - The location that contains this job.
|
| - *
|
| * [view] - The level of information requested in response.
|
| * Possible string values are:
|
| * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
|
| @@ -181,6 +179,8 @@ class ProjectsJobsResourceApi {
|
| * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
|
| * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
|
| *
|
| + * [location] - The location that contains this job.
|
| + *
|
| * Completes with a [Job].
|
| *
|
| * Completes with a [commons.ApiRequestError] if the API endpoint returned an
|
| @@ -189,7 +189,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<Job> get(core.String projectId, core.String jobId, {core.String location, core.String view}) {
|
| + async.Future<Job> get(core.String projectId, core.String jobId, {core.String view, core.String location}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -203,12 +203,12 @@ class ProjectsJobsResourceApi {
|
| if (jobId == null) {
|
| throw new core.ArgumentError("Parameter jobId is required.");
|
| }
|
| - if (location != null) {
|
| - _queryParams["location"] = [location];
|
| - }
|
| if (view != null) {
|
| _queryParams["view"] = [view];
|
| }
|
| + if (location != null) {
|
| + _queryParams["location"] = [location];
|
| + }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
|
|
|
| @@ -535,15 +535,6 @@ class ProjectsJobsMessagesResourceApi {
|
| *
|
| * [jobId] - The job to get messages about.
|
| *
|
| - * [startTime] - If specified, return only messages with timestamps >=
|
| - * start_time.
|
| - * The default is the job creation time (i.e. beginning of messages).
|
| - *
|
| - * [pageToken] - If supplied, this should be the value of next_page_token
|
| - * returned
|
| - * by an earlier call. This will cause the next page of results to
|
| - * be returned.
|
| - *
|
| * [pageSize] - If specified, determines the maximum number of messages to
|
| * return. If unspecified, the service may choose an appropriate
|
| * default, or may return an arbitrarily large number of results.
|
| @@ -557,12 +548,21 @@ class ProjectsJobsMessagesResourceApi {
|
| * - "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.
|
| + *
|
| + * [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).
|
| + *
|
| * Completes with a [ListJobMessagesResponse].
|
| *
|
| * Completes with a [commons.ApiRequestError] if the API endpoint returned an
|
| @@ -571,7 +571,7 @@ class ProjectsJobsMessagesResourceApi {
|
| * 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 startTime, core.String pageToken, core.int pageSize, core.String minimumImportance, core.String location, core.String endTime}) {
|
| + async.Future<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.int pageSize, core.String minimumImportance, core.String endTime, core.String location, core.String pageToken, core.String startTime}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -585,23 +585,23 @@ class ProjectsJobsMessagesResourceApi {
|
| if (jobId == null) {
|
| throw new core.ArgumentError("Parameter jobId is required.");
|
| }
|
| - 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];
|
| + }
|
| if (location != null) {
|
| _queryParams["location"] = [location];
|
| }
|
| - if (endTime != null) {
|
| - _queryParams["endTime"] = [endTime];
|
| + if (pageToken != null) {
|
| + _queryParams["pageToken"] = [pageToken];
|
| + }
|
| + if (startTime != null) {
|
| + _queryParams["startTime"] = [startTime];
|
| }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
|
| @@ -756,8 +756,6 @@ class ProjectsLocationsJobsResourceApi {
|
| *
|
| * [location] - The location that contains this job.
|
| *
|
| - * [replaceJobId] - Deprecated. This field is now in the Job message.
|
| - *
|
| * [view] - The level of information requested in response.
|
| * Possible string values are:
|
| * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
|
| @@ -765,6 +763,8 @@ class ProjectsLocationsJobsResourceApi {
|
| * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
|
| * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
|
| *
|
| + * [replaceJobId] - Deprecated. This field is now in the Job message.
|
| + *
|
| * Completes with a [Job].
|
| *
|
| * Completes with a [commons.ApiRequestError] if the API endpoint returned an
|
| @@ -773,7 +773,7 @@ class ProjectsLocationsJobsResourceApi {
|
| * If the used [http.Client] completes with an error when making a REST call,
|
| * this method will complete with the same error.
|
| */
|
| - async.Future<Job> create(Job request, core.String projectId, core.String location, {core.String replaceJobId, core.String view}) {
|
| + async.Future<Job> create(Job request, core.String projectId, core.String location, {core.String view, core.String replaceJobId}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -790,12 +790,12 @@ class ProjectsLocationsJobsResourceApi {
|
| if (location == null) {
|
| throw new core.ArgumentError("Parameter location is required.");
|
| }
|
| - if (replaceJobId != null) {
|
| - _queryParams["replaceJobId"] = [replaceJobId];
|
| - }
|
| if (view != null) {
|
| _queryParams["view"] = [view];
|
| }
|
| + if (replaceJobId != null) {
|
| + _queryParams["replaceJobId"] = [replaceJobId];
|
| + }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs';
|
|
|
| @@ -932,17 +932,6 @@ class ProjectsLocationsJobsResourceApi {
|
| *
|
| * [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.
|
| @@ -955,6 +944,17 @@ class ProjectsLocationsJobsResourceApi {
|
| * - "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.
|
| + *
|
| + * [pageToken] - Set this to the 'next_page_token' field of a previous
|
| + * response
|
| + * to request additional results in a long list.
|
| + *
|
| * Completes with a [ListJobsResponse].
|
| *
|
| * Completes with a [commons.ApiRequestError] if the API endpoint returned an
|
| @@ -963,7 +963,7 @@ class ProjectsLocationsJobsResourceApi {
|
| * 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.int pageSize, core.String view, core.String filter, core.String pageToken}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -977,18 +977,18 @@ class ProjectsLocationsJobsResourceApi {
|
| 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];
|
| + }
|
| + if (pageToken != null) {
|
| + _queryParams["pageToken"] = [pageToken];
|
| + }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs';
|
|
|
| @@ -1390,15 +1390,15 @@ class ProjectsTemplatesResourceApi {
|
| * [projectId] - Required. The ID of the Cloud Platform project that the job
|
| * belongs to.
|
| *
|
| - * [dryRun] - Whether or not the job should actually be executed after
|
| - * validating parameters. Defaults to false. Validation errors do
|
| - * not cause the HTTP request to fail if true.
|
| - *
|
| * [gcsPath] - Required. A Cloud Storage path to the template from which to
|
| * create
|
| * the job.
|
| * Must be valid Cloud Storage URL, beginning with 'gs://'.
|
| *
|
| + * [dryRun] - Whether or not the job should actually be executed after
|
| + * validating parameters. Defaults to false. Validation errors do
|
| + * not cause the HTTP request to fail if true.
|
| + *
|
| * Completes with a [LaunchTemplateResponse].
|
| *
|
| * Completes with a [commons.ApiRequestError] if the API endpoint returned an
|
| @@ -1407,7 +1407,7 @@ class ProjectsTemplatesResourceApi {
|
| * If the used [http.Client] completes with an error when making a REST call,
|
| * this method will complete with the same error.
|
| */
|
| - async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request, core.String projectId, {core.bool dryRun, core.String gcsPath}) {
|
| + async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request, core.String projectId, {core.String gcsPath, core.bool dryRun}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -1421,12 +1421,12 @@ class ProjectsTemplatesResourceApi {
|
| if (projectId == null) {
|
| throw new core.ArgumentError("Parameter projectId is required.");
|
| }
|
| - if (dryRun != null) {
|
| - _queryParams["dryRun"] = ["${dryRun}"];
|
| - }
|
| if (gcsPath != null) {
|
| _queryParams["gcsPath"] = [gcsPath];
|
| }
|
| + if (dryRun != null) {
|
| + _queryParams["dryRun"] = ["${dryRun}"];
|
| + }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/templates:launch';
|
|
|
| @@ -3843,13 +3843,13 @@ class KeyRangeLocation {
|
| * streaming computation cross-worker message delivery.
|
| */
|
| core.String deliveryEndpoint;
|
| - /** The end (exclusive) of the key range. */
|
| - core.String end;
|
| /**
|
| - * The location of the persistent state for this range, as a
|
| + * DEPRECATED. The location of the persistent state for this range, as a
|
| * persistent directory in the worker local filesystem.
|
| */
|
| - core.String persistentDirectory;
|
| + core.String deprecatedPersistentDirectory;
|
| + /** The end (exclusive) of the key range. */
|
| + core.String end;
|
| /** The start (inclusive) of the key range. */
|
| core.String start;
|
|
|
| @@ -3862,12 +3862,12 @@ class KeyRangeLocation {
|
| if (_json.containsKey("deliveryEndpoint")) {
|
| deliveryEndpoint = _json["deliveryEndpoint"];
|
| }
|
| + if (_json.containsKey("deprecatedPersistentDirectory")) {
|
| + deprecatedPersistentDirectory = _json["deprecatedPersistentDirectory"];
|
| + }
|
| if (_json.containsKey("end")) {
|
| end = _json["end"];
|
| }
|
| - if (_json.containsKey("persistentDirectory")) {
|
| - persistentDirectory = _json["persistentDirectory"];
|
| - }
|
| if (_json.containsKey("start")) {
|
| start = _json["start"];
|
| }
|
| @@ -3881,12 +3881,12 @@ class KeyRangeLocation {
|
| if (deliveryEndpoint != null) {
|
| _json["deliveryEndpoint"] = deliveryEndpoint;
|
| }
|
| + if (deprecatedPersistentDirectory != null) {
|
| + _json["deprecatedPersistentDirectory"] = deprecatedPersistentDirectory;
|
| + }
|
| if (end != null) {
|
| _json["end"] = end;
|
| }
|
| - if (persistentDirectory != null) {
|
| - _json["persistentDirectory"] = persistentDirectory;
|
| - }
|
| if (start != null) {
|
| _json["start"] = start;
|
| }
|
| @@ -3939,11 +3939,6 @@ class LaunchTemplateResponse {
|
| * the job was successfully launched.
|
| */
|
| Job job;
|
| - /**
|
| - * The status of the launch template request. Any problems with the request
|
| - * will be indicated in the error_details.
|
| - */
|
| - Status status;
|
|
|
| LaunchTemplateResponse();
|
|
|
| @@ -3951,9 +3946,6 @@ class LaunchTemplateResponse {
|
| if (_json.containsKey("job")) {
|
| job = new Job.fromJson(_json["job"]);
|
| }
|
| - if (_json.containsKey("status")) {
|
| - status = new Status.fromJson(_json["status"]);
|
| - }
|
| }
|
|
|
| core.Map toJson() {
|
| @@ -3961,9 +3953,6 @@ class LaunchTemplateResponse {
|
| if (job != null) {
|
| _json["job"] = (job).toJson();
|
| }
|
| - if (status != null) {
|
| - _json["status"] = (status).toJson();
|
| - }
|
| return _json;
|
| }
|
| }
|
|
|