From 0bbe518dae4d70d5bfdf061f6ee73bad63aa4ac6 Mon Sep 17 00:00:00 2001 From: Joo Wan Ro Date: Tue, 25 Jul 2017 14:07:20 -0700 Subject: [PATCH] Code gen for ADL (part 3) * Updating to the correct commit number: https://github.com/Azure/azure-rest-api-specs/pull/1452 --- .../Generated/AccountOperations.cs | 6 +- .../Generated/IJobOperations.cs | 18 +- .../Generated/JobOperations.cs | 56 +++--- .../Generated/JobOperationsExtensions.cs | 44 ++--- .../Generated/Models/JobStateAuditRecord.cs | 4 +- .../generate.cmd | 6 +- .../Generated/AccountOperations.cs | 6 +- .../Generated/FileSystemOperations.cs | 176 +++++++++--------- .../FileSystemOperationsExtensions.cs | 138 +++++++------- .../Generated/IFileSystemOperations.cs | 84 ++++----- .../Management.DataLake.Store/generate.cmd | 4 +- 11 files changed, 271 insertions(+), 271 deletions(-) diff --git a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/AccountOperations.cs b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/AccountOperations.cs index f34b85e15677f..e06310e86aa30 100644 --- a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/AccountOperations.cs +++ b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/AccountOperations.cs @@ -906,7 +906,7 @@ internal AccountOperations(DataLakeAnalyticsAccountManagementClient client) HttpStatusCode _statusCode = _httpResponse.StatusCode; cancellationToken.ThrowIfCancellationRequested(); string _responseContent = null; - if ((int)_statusCode != 201 && (int)_statusCode != 200) + if ((int)_statusCode != 200 && (int)_statusCode != 201) { var ex = new CloudException(string.Format("Operation returned an invalid status code '{0}'", _statusCode)); try @@ -949,7 +949,7 @@ internal AccountOperations(DataLakeAnalyticsAccountManagementClient client) _result.RequestId = _httpResponse.Headers.GetValues("x-ms-request-id").FirstOrDefault(); } // Deserialize Response - if ((int)_statusCode == 201) + if ((int)_statusCode == 200) { _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); try @@ -967,7 +967,7 @@ internal AccountOperations(DataLakeAnalyticsAccountManagementClient client) } } // Deserialize Response - if ((int)_statusCode == 200) + if ((int)_statusCode == 201) { _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); try diff --git a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/IJobOperations.cs b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/IJobOperations.cs index 9b6a5ff7f7713..690b145687ad7 100644 --- a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/IJobOperations.cs +++ b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/IJobOperations.cs @@ -124,13 +124,16 @@ public partial interface IJobOperations /// Task CancelWithHttpMessagesAsync(string accountName, System.Guid jobIdentity, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// - /// Gets the job information for the specified job ID. + /// Submits a job to the specified Data Lake Analytics account. /// /// /// The Azure Data Lake Analytics account to execute job operations on. /// /// - /// JobInfo ID. + /// The job ID (a GUID) for the job being submitted. + /// + /// + /// The parameters to submit a job. /// /// /// The headers that will be added to request. @@ -147,18 +150,15 @@ public partial interface IJobOperations /// /// Thrown when a required parameter is null /// - Task> GetWithHttpMessagesAsync(string accountName, System.Guid jobIdentity, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> CreateWithHttpMessagesAsync(string accountName, System.Guid jobIdentity, CreateJobParameters parameters, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// - /// Submits a job to the specified Data Lake Analytics account. + /// Gets the job information for the specified job ID. /// /// /// The Azure Data Lake Analytics account to execute job operations on. /// /// - /// The job ID (a GUID) for the job being submitted. - /// - /// - /// The parameters to submit a job. + /// JobInfo ID. /// /// /// The headers that will be added to request. @@ -175,7 +175,7 @@ public partial interface IJobOperations /// /// Thrown when a required parameter is null /// - Task> CreateWithHttpMessagesAsync(string accountName, System.Guid jobIdentity, CreateJobParameters parameters, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); + Task> GetWithHttpMessagesAsync(string accountName, System.Guid jobIdentity, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// Lists the jobs, if any, associated with the specified Data Lake /// Analytics account. The response includes a link to the next page of diff --git a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/JobOperations.cs b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/JobOperations.cs index 01d488502047f..91016c93eff94 100644 --- a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/JobOperations.cs +++ b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/JobOperations.cs @@ -814,13 +814,16 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) } /// - /// Gets the job information for the specified job ID. + /// Submits a job to the specified Data Lake Analytics account. /// /// /// The Azure Data Lake Analytics account to execute job operations on. /// /// - /// JobInfo ID. + /// The job ID (a GUID) for the job being submitted. + /// + /// + /// The parameters to submit a job. /// /// /// Headers that will be added to request. @@ -843,7 +846,7 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) /// /// A response object containing the response body and response headers. /// - public async Task> GetWithHttpMessagesAsync(string accountName, System.Guid jobIdentity, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> CreateWithHttpMessagesAsync(string accountName, System.Guid jobIdentity, CreateJobParameters parameters, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (accountName == null) { @@ -853,6 +856,14 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) { throw new ValidationException(ValidationRules.CannotBeNull, "this.Client.AdlaJobDnsSuffix"); } + if (parameters == null) + { + throw new ValidationException(ValidationRules.CannotBeNull, "parameters"); + } + if (parameters != null) + { + parameters.Validate(); + } if (Client.ApiVersion == null) { throw new ValidationException(ValidationRules.CannotBeNull, "this.Client.ApiVersion"); @@ -866,8 +877,9 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) Dictionary tracingParameters = new Dictionary(); tracingParameters.Add("accountName", accountName); tracingParameters.Add("jobIdentity", jobIdentity); + tracingParameters.Add("parameters", parameters); tracingParameters.Add("cancellationToken", cancellationToken); - ServiceClientTracing.Enter(_invocationId, this, "Get", tracingParameters); + ServiceClientTracing.Enter(_invocationId, this, "Create", tracingParameters); } // Construct URL var _baseUrl = Client.BaseUri; @@ -887,7 +899,7 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) // Create HTTP transport objects var _httpRequest = new HttpRequestMessage(); HttpResponseMessage _httpResponse = null; - _httpRequest.Method = new HttpMethod("GET"); + _httpRequest.Method = new HttpMethod("PUT"); _httpRequest.RequestUri = new System.Uri(_url); // Set Headers if (Client.GenerateClientRequestId != null && Client.GenerateClientRequestId.Value) @@ -918,6 +930,12 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) // Serialize Request string _requestContent = null; + if(parameters != null) + { + _requestContent = Rest.Serialization.SafeJsonConvert.SerializeObject(parameters, Client.SerializationSettings); + _httpRequest.Content = new StringContent(_requestContent, System.Text.Encoding.UTF8); + _httpRequest.Content.Headers.ContentType =System.Net.Http.Headers.MediaTypeHeaderValue.Parse("application/json; charset=utf-8"); + } // Set Credentials if (Client.Credentials != null) { @@ -1006,16 +1024,13 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) } /// - /// Submits a job to the specified Data Lake Analytics account. + /// Gets the job information for the specified job ID. /// /// /// The Azure Data Lake Analytics account to execute job operations on. /// /// - /// The job ID (a GUID) for the job being submitted. - /// - /// - /// The parameters to submit a job. + /// JobInfo ID. /// /// /// Headers that will be added to request. @@ -1038,7 +1053,7 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) /// /// A response object containing the response body and response headers. /// - public async Task> CreateWithHttpMessagesAsync(string accountName, System.Guid jobIdentity, CreateJobParameters parameters, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task> GetWithHttpMessagesAsync(string accountName, System.Guid jobIdentity, Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (accountName == null) { @@ -1048,14 +1063,6 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) { throw new ValidationException(ValidationRules.CannotBeNull, "this.Client.AdlaJobDnsSuffix"); } - if (parameters == null) - { - throw new ValidationException(ValidationRules.CannotBeNull, "parameters"); - } - if (parameters != null) - { - parameters.Validate(); - } if (Client.ApiVersion == null) { throw new ValidationException(ValidationRules.CannotBeNull, "this.Client.ApiVersion"); @@ -1069,9 +1076,8 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) Dictionary tracingParameters = new Dictionary(); tracingParameters.Add("accountName", accountName); tracingParameters.Add("jobIdentity", jobIdentity); - tracingParameters.Add("parameters", parameters); tracingParameters.Add("cancellationToken", cancellationToken); - ServiceClientTracing.Enter(_invocationId, this, "Create", tracingParameters); + ServiceClientTracing.Enter(_invocationId, this, "Get", tracingParameters); } // Construct URL var _baseUrl = Client.BaseUri; @@ -1091,7 +1097,7 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) // Create HTTP transport objects var _httpRequest = new HttpRequestMessage(); HttpResponseMessage _httpResponse = null; - _httpRequest.Method = new HttpMethod("PUT"); + _httpRequest.Method = new HttpMethod("GET"); _httpRequest.RequestUri = new System.Uri(_url); // Set Headers if (Client.GenerateClientRequestId != null && Client.GenerateClientRequestId.Value) @@ -1122,12 +1128,6 @@ internal JobOperations(DataLakeAnalyticsJobManagementClient client) // Serialize Request string _requestContent = null; - if(parameters != null) - { - _requestContent = Rest.Serialization.SafeJsonConvert.SerializeObject(parameters, Client.SerializationSettings); - _httpRequest.Content = new StringContent(_requestContent, System.Text.Encoding.UTF8); - _httpRequest.Content.Headers.ContentType =System.Net.Http.Headers.MediaTypeHeaderValue.Parse("application/json; charset=utf-8"); - } // Set Credentials if (Client.Credentials != null) { diff --git a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/JobOperationsExtensions.cs b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/JobOperationsExtensions.cs index 213c916af52fe..de2f63d116963 100644 --- a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/JobOperationsExtensions.cs +++ b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/JobOperationsExtensions.cs @@ -183,7 +183,7 @@ public static void Cancel(this IJobOperations operations, string accountName, Sy } /// - /// Gets the job information for the specified job ID. + /// Submits a job to the specified Data Lake Analytics account. /// /// /// The operations group for this extension method. @@ -192,15 +192,18 @@ public static void Cancel(this IJobOperations operations, string accountName, Sy /// The Azure Data Lake Analytics account to execute job operations on. /// /// - /// JobInfo ID. + /// The job ID (a GUID) for the job being submitted. /// - public static JobInformation Get(this IJobOperations operations, string accountName, System.Guid jobIdentity) + /// + /// The parameters to submit a job. + /// + public static JobInformation Create(this IJobOperations operations, string accountName, System.Guid jobIdentity, CreateJobParameters parameters) { - return operations.GetAsync(accountName, jobIdentity).GetAwaiter().GetResult(); + return operations.CreateAsync(accountName, jobIdentity, parameters).GetAwaiter().GetResult(); } /// - /// Gets the job information for the specified job ID. + /// Submits a job to the specified Data Lake Analytics account. /// /// /// The operations group for this extension method. @@ -209,21 +212,24 @@ public static JobInformation Get(this IJobOperations operations, string accountN /// The Azure Data Lake Analytics account to execute job operations on. /// /// - /// JobInfo ID. + /// The job ID (a GUID) for the job being submitted. + /// + /// + /// The parameters to submit a job. /// /// /// The cancellation token. /// - public static async Task GetAsync(this IJobOperations operations, string accountName, System.Guid jobIdentity, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task CreateAsync(this IJobOperations operations, string accountName, System.Guid jobIdentity, CreateJobParameters parameters, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.GetWithHttpMessagesAsync(accountName, jobIdentity, null, cancellationToken).ConfigureAwait(false)) + using (var _result = await operations.CreateWithHttpMessagesAsync(accountName, jobIdentity, parameters, null, cancellationToken).ConfigureAwait(false)) { return _result.Body; } } /// - /// Submits a job to the specified Data Lake Analytics account. + /// Gets the job information for the specified job ID. /// /// /// The operations group for this extension method. @@ -232,18 +238,15 @@ public static JobInformation Get(this IJobOperations operations, string accountN /// The Azure Data Lake Analytics account to execute job operations on. /// /// - /// The job ID (a GUID) for the job being submitted. - /// - /// - /// The parameters to submit a job. + /// JobInfo ID. /// - public static JobInformation Create(this IJobOperations operations, string accountName, System.Guid jobIdentity, CreateJobParameters parameters) + public static JobInformation Get(this IJobOperations operations, string accountName, System.Guid jobIdentity) { - return operations.CreateAsync(accountName, jobIdentity, parameters).GetAwaiter().GetResult(); + return operations.GetAsync(accountName, jobIdentity).GetAwaiter().GetResult(); } /// - /// Submits a job to the specified Data Lake Analytics account. + /// Gets the job information for the specified job ID. /// /// /// The operations group for this extension method. @@ -252,17 +255,14 @@ public static JobInformation Create(this IJobOperations operations, string accou /// The Azure Data Lake Analytics account to execute job operations on. /// /// - /// The job ID (a GUID) for the job being submitted. - /// - /// - /// The parameters to submit a job. + /// JobInfo ID. /// /// /// The cancellation token. /// - public static async Task CreateAsync(this IJobOperations operations, string accountName, System.Guid jobIdentity, CreateJobParameters parameters, CancellationToken cancellationToken = default(CancellationToken)) + public static async Task GetAsync(this IJobOperations operations, string accountName, System.Guid jobIdentity, CancellationToken cancellationToken = default(CancellationToken)) { - using (var _result = await operations.CreateWithHttpMessagesAsync(accountName, jobIdentity, parameters, null, cancellationToken).ConfigureAwait(false)) + using (var _result = await operations.GetWithHttpMessagesAsync(accountName, jobIdentity, null, cancellationToken).ConfigureAwait(false)) { return _result.Body; } diff --git a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/Models/JobStateAuditRecord.cs b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/Models/JobStateAuditRecord.cs index 28c7fbeca1e11..04b62a6b4ee6e 100644 --- a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/Models/JobStateAuditRecord.cs +++ b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/Generated/Models/JobStateAuditRecord.cs @@ -37,7 +37,7 @@ public JobStateAuditRecord() /// place. /// the user who requests the /// change. - /// the details of the audit log. + /// the details of the audit log. public JobStateAuditRecord(string newState = default(string), System.DateTimeOffset? timeStamp = default(System.DateTimeOffset?), string requestedByUser = default(string), string details = default(string)) { NewState = newState; @@ -71,7 +71,7 @@ public JobStateAuditRecord() public string RequestedByUser { get; private set; } /// - /// Gets the details of the audit log. + /// Gets the details of the audit log. /// [JsonProperty(PropertyName = "details")] public string Details { get; private set; } diff --git a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/generate.cmd b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/generate.cmd index 1a6cee306086e..d1e4b9027bb0f 100644 --- a/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/generate.cmd +++ b/src/SDKs/DataLake.Analytics/Management.DataLake.Analytics/generate.cmd @@ -6,9 +6,9 @@ @echo off setlocal -set accountSpecFile="https://raw.githubusercontent.com/Azure/azure-rest-api-specs/5f839ce3d1f11a3107a61375a61580ff1353b98b/specification/datalake-analytics/resource-manager/Microsoft.DataLakeAnalytics/2016-11-01/account.json" -set jobSpecFile="https://raw.githubusercontent.com/Azure/azure-rest-api-specs/5f839ce3d1f11a3107a61375a61580ff1353b98b/specification/datalake-analytics/data-plane/Microsoft.DataLakeAnalytics/2016-11-01/job.json" -set catalogSpecFile="https://raw.githubusercontent.com/Azure/azure-rest-api-specs/5f839ce3d1f11a3107a61375a61580ff1353b98b/specification/datalake-analytics/data-plane/Microsoft.DataLakeAnalytics/2016-11-01/catalog.json" +set accountSpecFile="https://raw.githubusercontent.com/Azure/azure-rest-api-specs/91edc3084d674ecabb105584ad926d4d8449b054/specification/datalake-analytics/resource-manager/Microsoft.DataLakeAnalytics/2016-11-01/account.json" +set jobSpecFile="https://raw.githubusercontent.com/Azure/azure-rest-api-specs/91edc3084d674ecabb105584ad926d4d8449b054/specification/datalake-analytics/data-plane/Microsoft.DataLakeAnalytics/2016-11-01/job.json" +set catalogSpecFile="https://raw.githubusercontent.com/Azure/azure-rest-api-specs/91edc3084d674ecabb105584ad926d4d8449b054/specification/datalake-analytics/data-plane/Microsoft.DataLakeAnalytics/2016-11-01/catalog.json" set repoRoot=%~dp0..\..\..\.. set generateFolder=%~dp0Generated diff --git a/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/AccountOperations.cs b/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/AccountOperations.cs index 5c1b87f6dbc6b..4b00c3c4c1127 100644 --- a/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/AccountOperations.cs +++ b/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/AccountOperations.cs @@ -1084,7 +1084,7 @@ internal AccountOperations(DataLakeStoreAccountManagementClient client) HttpStatusCode _statusCode = _httpResponse.StatusCode; cancellationToken.ThrowIfCancellationRequested(); string _responseContent = null; - if ((int)_statusCode != 201 && (int)_statusCode != 200) + if ((int)_statusCode != 200 && (int)_statusCode != 201) { var ex = new CloudException(string.Format("Operation returned an invalid status code '{0}'", _statusCode)); try @@ -1127,7 +1127,7 @@ internal AccountOperations(DataLakeStoreAccountManagementClient client) _result.RequestId = _httpResponse.Headers.GetValues("x-ms-request-id").FirstOrDefault(); } // Deserialize Response - if ((int)_statusCode == 201) + if ((int)_statusCode == 200) { _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); try @@ -1145,7 +1145,7 @@ internal AccountOperations(DataLakeStoreAccountManagementClient client) } } // Deserialize Response - if ((int)_statusCode == 200) + if ((int)_statusCode == 201) { _responseContent = await _httpResponse.Content.ReadAsStringAsync().ConfigureAwait(false); try diff --git a/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/FileSystemOperations.cs b/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/FileSystemOperations.cs index 17b651ae686cc..9ac422ca22c0c 100644 --- a/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/FileSystemOperations.cs +++ b/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/FileSystemOperations.cs @@ -53,40 +53,29 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) public DataLakeStoreFileSystemManagementClient Client { get; private set; } /// - /// Appends to the specified file, optionally first creating the file if it - /// does not yet exist. This method supports multiple concurrent appends to the - /// file. NOTE: The target must not contain data added by Create or normal - /// (serial) Append. ConcurrentAppend and Append cannot be used - /// interchangeably; once a target file has been modified using either of these - /// append options, the other append option cannot be used on the target file. - /// ConcurrentAppend does not guarantee order and can result in duplicated data - /// landing in the target file. + /// Sets or removes the expiration time on the specified file. This operation + /// can only be executed against files. Folders are not supported. /// /// /// The Azure Data Lake Store account to execute filesystem operations on. /// /// - /// The Data Lake Store path (starting with '/') of the file to which to append - /// using concurrent append. - /// - /// - /// The file contents to include when appending to the file. + /// The Data Lake Store path (starting with '/') of the file on which to set or + /// remove the expiration time. /// - /// - /// Indicates the concurrent append call should create the file if it doesn't - /// exist or just open the existing file for append. Possible values include: - /// 'autocreate' + /// + /// Indicates the type of expiration to use for the file: 1. NeverExpire: + /// ExpireTime is ignored. 2. RelativeToNow: ExpireTime is an integer in + /// milliseconds representing the expiration date relative to when file + /// expiration is updated. 3. RelativeToCreationDate: ExpireTime is an integer + /// in milliseconds representing the expiration date relative to file creation. + /// 4. Absolute: ExpireTime is an integer in milliseconds, as a Unix timestamp + /// relative to 1/1/1970 00:00:00. Possible values include: 'NeverExpire', + /// 'RelativeToNow', 'RelativeToCreationDate', 'Absolute' /// - /// - /// Optionally indicates what to do after completion of the concurrent append. - /// DATA indicates that more data will be sent immediately by the client, the - /// file handle should remain open/locked, and file metadata (including file - /// length, last modified time) should NOT get updated. METADATA indicates that - /// more data will be sent immediately by the client, the file handle should - /// remain open/locked, and file metadata should get updated. CLOSE indicates - /// that the client is done sending data, the file handle should be - /// closed/unlocked, and file metadata should get updated. Possible values - /// include: 'DATA', 'METADATA', 'CLOSE' + /// + /// The time that the file will expire, corresponding to the ExpiryOption that + /// was set. /// /// /// Headers that will be added to request. @@ -106,7 +95,7 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) /// /// A response object containing the response body and response headers. /// - public async Task ConcurrentAppendWithHttpMessagesAsync(string accountName, string path, Stream streamContents, AppendModeType? appendMode = default(AppendModeType?), SyncFlag? syncFlag = default(SyncFlag?), Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task SetFileExpiryWithHttpMessagesAsync(string accountName, string path, ExpiryOptionType expiryOption, long? expireTime = default(long?), Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (accountName == null) { @@ -120,16 +109,11 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) { throw new ValidationException(ValidationRules.CannotBeNull, "path"); } - if (streamContents == null) - { - throw new ValidationException(ValidationRules.CannotBeNull, "streamContents"); - } if (Client.ApiVersion == null) { throw new ValidationException(ValidationRules.CannotBeNull, "this.Client.ApiVersion"); } - string op = "CONCURRENTAPPEND"; - string transferEncoding = "chunked"; + string op = "SETEXPIRY"; // Tracing bool _shouldTrace = ServiceClientTracing.IsEnabled; string _invocationId = null; @@ -139,13 +123,11 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) Dictionary tracingParameters = new Dictionary(); tracingParameters.Add("accountName", accountName); tracingParameters.Add("path", path); - tracingParameters.Add("streamContents", streamContents); - tracingParameters.Add("appendMode", appendMode); + tracingParameters.Add("expiryOption", expiryOption); + tracingParameters.Add("expireTime", expireTime); tracingParameters.Add("op", op); - tracingParameters.Add("transferEncoding", transferEncoding); - tracingParameters.Add("syncFlag", syncFlag); tracingParameters.Add("cancellationToken", cancellationToken); - ServiceClientTracing.Enter(_invocationId, this, "ConcurrentAppend", tracingParameters); + ServiceClientTracing.Enter(_invocationId, this, "SetFileExpiry", tracingParameters); } // Construct URL var _baseUrl = Client.BaseUri; @@ -154,18 +136,15 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) _url = _url.Replace("{adlsFileSystemDnsSuffix}", Client.AdlsFileSystemDnsSuffix); _url = _url.Replace("{path}", System.Uri.EscapeDataString(path)); List _queryParameters = new List(); - if (appendMode != null) + _queryParameters.Add(string.Format("expiryOption={0}", System.Uri.EscapeDataString(Rest.Serialization.SafeJsonConvert.SerializeObject(expiryOption, Client.SerializationSettings).Trim('"')))); + if (expireTime != null) { - _queryParameters.Add(string.Format("appendMode={0}", System.Uri.EscapeDataString(Rest.Serialization.SafeJsonConvert.SerializeObject(appendMode, Client.SerializationSettings).Trim('"')))); + _queryParameters.Add(string.Format("expireTime={0}", System.Uri.EscapeDataString(Rest.Serialization.SafeJsonConvert.SerializeObject(expireTime, Client.SerializationSettings).Trim('"')))); } if (op != null) { _queryParameters.Add(string.Format("op={0}", System.Uri.EscapeDataString(op))); } - if (syncFlag != null) - { - _queryParameters.Add(string.Format("syncFlag={0}", System.Uri.EscapeDataString(Rest.Serialization.SafeJsonConvert.SerializeObject(syncFlag, Client.SerializationSettings).Trim('"')))); - } if (Client.ApiVersion != null) { _queryParameters.Add(string.Format("api-version={0}", System.Uri.EscapeDataString(Client.ApiVersion))); @@ -177,21 +156,13 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) // Create HTTP transport objects var _httpRequest = new HttpRequestMessage(); HttpResponseMessage _httpResponse = null; - _httpRequest.Method = new HttpMethod("POST"); + _httpRequest.Method = new HttpMethod("PUT"); _httpRequest.RequestUri = new System.Uri(_url); // Set Headers if (Client.GenerateClientRequestId != null && Client.GenerateClientRequestId.Value) { _httpRequest.Headers.TryAddWithoutValidation("x-ms-client-request-id", System.Guid.NewGuid().ToString()); } - if (transferEncoding != null) - { - if (_httpRequest.Headers.Contains("Transfer-Encoding")) - { - _httpRequest.Headers.Remove("Transfer-Encoding"); - } - _httpRequest.Headers.TryAddWithoutValidation("Transfer-Encoding", transferEncoding); - } if (Client.AcceptLanguage != null) { if (_httpRequest.Headers.Contains("accept-language")) @@ -216,15 +187,6 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) // Serialize Request string _requestContent = null; - if(streamContents == null) - { - throw new System.ArgumentNullException("streamContents"); - } - if (streamContents != null && streamContents != Stream.Null) - { - _httpRequest.Content = new StreamContent(streamContents); - _httpRequest.Content.Headers.ContentType =System.Net.Http.Headers.MediaTypeHeaderValue.Parse("application/octet-stream"); - } // Set Credentials if (Client.Credentials != null) { @@ -290,29 +252,40 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) } /// - /// Sets or removes the expiration time on the specified file. This operation - /// can only be executed against files. Folders are not supported. + /// Appends to the specified file, optionally first creating the file if it + /// does not yet exist. This method supports multiple concurrent appends to the + /// file. NOTE: The target must not contain data added by Create or normal + /// (serial) Append. ConcurrentAppend and Append cannot be used + /// interchangeably; once a target file has been modified using either of these + /// append options, the other append option cannot be used on the target file. + /// ConcurrentAppend does not guarantee order and can result in duplicated data + /// landing in the target file. /// /// /// The Azure Data Lake Store account to execute filesystem operations on. /// /// - /// The Data Lake Store path (starting with '/') of the file on which to set or - /// remove the expiration time. + /// The Data Lake Store path (starting with '/') of the file to which to append + /// using concurrent append. /// - /// - /// Indicates the type of expiration to use for the file: 1. NeverExpire: - /// ExpireTime is ignored. 2. RelativeToNow: ExpireTime is an integer in - /// milliseconds representing the expiration date relative to when file - /// expiration is updated. 3. RelativeToCreationDate: ExpireTime is an integer - /// in milliseconds representing the expiration date relative to file creation. - /// 4. Absolute: ExpireTime is an integer in milliseconds, as a Unix timestamp - /// relative to 1/1/1970 00:00:00. Possible values include: 'NeverExpire', - /// 'RelativeToNow', 'RelativeToCreationDate', 'Absolute' + /// + /// The file contents to include when appending to the file. /// - /// - /// The time that the file will expire, corresponding to the ExpiryOption that - /// was set. + /// + /// Indicates the concurrent append call should create the file if it doesn't + /// exist or just open the existing file for append. Possible values include: + /// 'autocreate' + /// + /// + /// Optionally indicates what to do after completion of the concurrent append. + /// DATA indicates that more data will be sent immediately by the client, the + /// file handle should remain open/locked, and file metadata (including file + /// length, last modified time) should NOT get updated. METADATA indicates that + /// more data will be sent immediately by the client, the file handle should + /// remain open/locked, and file metadata should get updated. CLOSE indicates + /// that the client is done sending data, the file handle should be + /// closed/unlocked, and file metadata should get updated. Possible values + /// include: 'DATA', 'METADATA', 'CLOSE' /// /// /// Headers that will be added to request. @@ -332,7 +305,7 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) /// /// A response object containing the response body and response headers. /// - public async Task SetFileExpiryWithHttpMessagesAsync(string accountName, string path, ExpiryOptionType expiryOption, long? expireTime = default(long?), Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) + public async Task ConcurrentAppendWithHttpMessagesAsync(string accountName, string path, Stream streamContents, AppendModeType? appendMode = default(AppendModeType?), SyncFlag? syncFlag = default(SyncFlag?), Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)) { if (accountName == null) { @@ -346,11 +319,16 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) { throw new ValidationException(ValidationRules.CannotBeNull, "path"); } + if (streamContents == null) + { + throw new ValidationException(ValidationRules.CannotBeNull, "streamContents"); + } if (Client.ApiVersion == null) { throw new ValidationException(ValidationRules.CannotBeNull, "this.Client.ApiVersion"); } - string op = "SETEXPIRY"; + string op = "CONCURRENTAPPEND"; + string transferEncoding = "chunked"; // Tracing bool _shouldTrace = ServiceClientTracing.IsEnabled; string _invocationId = null; @@ -360,11 +338,13 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) Dictionary tracingParameters = new Dictionary(); tracingParameters.Add("accountName", accountName); tracingParameters.Add("path", path); - tracingParameters.Add("expiryOption", expiryOption); - tracingParameters.Add("expireTime", expireTime); + tracingParameters.Add("streamContents", streamContents); + tracingParameters.Add("appendMode", appendMode); tracingParameters.Add("op", op); + tracingParameters.Add("transferEncoding", transferEncoding); + tracingParameters.Add("syncFlag", syncFlag); tracingParameters.Add("cancellationToken", cancellationToken); - ServiceClientTracing.Enter(_invocationId, this, "SetFileExpiry", tracingParameters); + ServiceClientTracing.Enter(_invocationId, this, "ConcurrentAppend", tracingParameters); } // Construct URL var _baseUrl = Client.BaseUri; @@ -373,15 +353,18 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) _url = _url.Replace("{adlsFileSystemDnsSuffix}", Client.AdlsFileSystemDnsSuffix); _url = _url.Replace("{path}", System.Uri.EscapeDataString(path)); List _queryParameters = new List(); - _queryParameters.Add(string.Format("expiryOption={0}", System.Uri.EscapeDataString(Rest.Serialization.SafeJsonConvert.SerializeObject(expiryOption, Client.SerializationSettings).Trim('"')))); - if (expireTime != null) + if (appendMode != null) { - _queryParameters.Add(string.Format("expireTime={0}", System.Uri.EscapeDataString(Rest.Serialization.SafeJsonConvert.SerializeObject(expireTime, Client.SerializationSettings).Trim('"')))); + _queryParameters.Add(string.Format("appendMode={0}", System.Uri.EscapeDataString(Rest.Serialization.SafeJsonConvert.SerializeObject(appendMode, Client.SerializationSettings).Trim('"')))); } if (op != null) { _queryParameters.Add(string.Format("op={0}", System.Uri.EscapeDataString(op))); } + if (syncFlag != null) + { + _queryParameters.Add(string.Format("syncFlag={0}", System.Uri.EscapeDataString(Rest.Serialization.SafeJsonConvert.SerializeObject(syncFlag, Client.SerializationSettings).Trim('"')))); + } if (Client.ApiVersion != null) { _queryParameters.Add(string.Format("api-version={0}", System.Uri.EscapeDataString(Client.ApiVersion))); @@ -393,13 +376,21 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) // Create HTTP transport objects var _httpRequest = new HttpRequestMessage(); HttpResponseMessage _httpResponse = null; - _httpRequest.Method = new HttpMethod("PUT"); + _httpRequest.Method = new HttpMethod("POST"); _httpRequest.RequestUri = new System.Uri(_url); // Set Headers if (Client.GenerateClientRequestId != null && Client.GenerateClientRequestId.Value) { _httpRequest.Headers.TryAddWithoutValidation("x-ms-client-request-id", System.Guid.NewGuid().ToString()); } + if (transferEncoding != null) + { + if (_httpRequest.Headers.Contains("Transfer-Encoding")) + { + _httpRequest.Headers.Remove("Transfer-Encoding"); + } + _httpRequest.Headers.TryAddWithoutValidation("Transfer-Encoding", transferEncoding); + } if (Client.AcceptLanguage != null) { if (_httpRequest.Headers.Contains("accept-language")) @@ -424,6 +415,15 @@ internal FileSystemOperations(DataLakeStoreFileSystemManagementClient client) // Serialize Request string _requestContent = null; + if(streamContents == null) + { + throw new System.ArgumentNullException("streamContents"); + } + if (streamContents != null && streamContents != Stream.Null) + { + _httpRequest.Content = new StreamContent(streamContents); + _httpRequest.Content.Headers.ContentType =System.Net.Http.Headers.MediaTypeHeaderValue.Parse("application/octet-stream"); + } // Set Credentials if (Client.Credentials != null) { diff --git a/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/FileSystemOperationsExtensions.cs b/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/FileSystemOperationsExtensions.cs index 8f5fd8d239459..3ad4a23aa271f 100644 --- a/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/FileSystemOperationsExtensions.cs +++ b/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/FileSystemOperationsExtensions.cs @@ -25,6 +25,75 @@ namespace Microsoft.Azure.Management.DataLake.Store /// public static partial class FileSystemOperationsExtensions { + /// + /// Sets or removes the expiration time on the specified file. This operation + /// can only be executed against files. Folders are not supported. + /// + /// + /// The operations group for this extension method. + /// + /// + /// The Azure Data Lake Store account to execute filesystem operations on. + /// + /// + /// The Data Lake Store path (starting with '/') of the file on which to set or + /// remove the expiration time. + /// + /// + /// Indicates the type of expiration to use for the file: 1. NeverExpire: + /// ExpireTime is ignored. 2. RelativeToNow: ExpireTime is an integer in + /// milliseconds representing the expiration date relative to when file + /// expiration is updated. 3. RelativeToCreationDate: ExpireTime is an integer + /// in milliseconds representing the expiration date relative to file creation. + /// 4. Absolute: ExpireTime is an integer in milliseconds, as a Unix timestamp + /// relative to 1/1/1970 00:00:00. Possible values include: 'NeverExpire', + /// 'RelativeToNow', 'RelativeToCreationDate', 'Absolute' + /// + /// + /// The time that the file will expire, corresponding to the ExpiryOption that + /// was set. + /// + public static void SetFileExpiry(this IFileSystemOperations operations, string accountName, string path, ExpiryOptionType expiryOption, long? expireTime = default(long?)) + { + operations.SetFileExpiryAsync(accountName, path, expiryOption, expireTime).GetAwaiter().GetResult(); + } + + /// + /// Sets or removes the expiration time on the specified file. This operation + /// can only be executed against files. Folders are not supported. + /// + /// + /// The operations group for this extension method. + /// + /// + /// The Azure Data Lake Store account to execute filesystem operations on. + /// + /// + /// The Data Lake Store path (starting with '/') of the file on which to set or + /// remove the expiration time. + /// + /// + /// Indicates the type of expiration to use for the file: 1. NeverExpire: + /// ExpireTime is ignored. 2. RelativeToNow: ExpireTime is an integer in + /// milliseconds representing the expiration date relative to when file + /// expiration is updated. 3. RelativeToCreationDate: ExpireTime is an integer + /// in milliseconds representing the expiration date relative to file creation. + /// 4. Absolute: ExpireTime is an integer in milliseconds, as a Unix timestamp + /// relative to 1/1/1970 00:00:00. Possible values include: 'NeverExpire', + /// 'RelativeToNow', 'RelativeToCreationDate', 'Absolute' + /// + /// + /// The time that the file will expire, corresponding to the ExpiryOption that + /// was set. + /// + /// + /// The cancellation token. + /// + public static async Task SetFileExpiryAsync(this IFileSystemOperations operations, string accountName, string path, ExpiryOptionType expiryOption, long? expireTime = default(long?), CancellationToken cancellationToken = default(CancellationToken)) + { + (await operations.SetFileExpiryWithHttpMessagesAsync(accountName, path, expiryOption, expireTime, null, cancellationToken).ConfigureAwait(false)).Dispose(); + } + /// /// Appends to the specified file, optionally first creating the file if it /// does not yet exist. This method supports multiple concurrent appends to the @@ -116,75 +185,6 @@ public static partial class FileSystemOperationsExtensions (await operations.ConcurrentAppendWithHttpMessagesAsync(accountName, path, streamContents, appendMode, syncFlag, null, cancellationToken).ConfigureAwait(false)).Dispose(); } - /// - /// Sets or removes the expiration time on the specified file. This operation - /// can only be executed against files. Folders are not supported. - /// - /// - /// The operations group for this extension method. - /// - /// - /// The Azure Data Lake Store account to execute filesystem operations on. - /// - /// - /// The Data Lake Store path (starting with '/') of the file on which to set or - /// remove the expiration time. - /// - /// - /// Indicates the type of expiration to use for the file: 1. NeverExpire: - /// ExpireTime is ignored. 2. RelativeToNow: ExpireTime is an integer in - /// milliseconds representing the expiration date relative to when file - /// expiration is updated. 3. RelativeToCreationDate: ExpireTime is an integer - /// in milliseconds representing the expiration date relative to file creation. - /// 4. Absolute: ExpireTime is an integer in milliseconds, as a Unix timestamp - /// relative to 1/1/1970 00:00:00. Possible values include: 'NeverExpire', - /// 'RelativeToNow', 'RelativeToCreationDate', 'Absolute' - /// - /// - /// The time that the file will expire, corresponding to the ExpiryOption that - /// was set. - /// - public static void SetFileExpiry(this IFileSystemOperations operations, string accountName, string path, ExpiryOptionType expiryOption, long? expireTime = default(long?)) - { - operations.SetFileExpiryAsync(accountName, path, expiryOption, expireTime).GetAwaiter().GetResult(); - } - - /// - /// Sets or removes the expiration time on the specified file. This operation - /// can only be executed against files. Folders are not supported. - /// - /// - /// The operations group for this extension method. - /// - /// - /// The Azure Data Lake Store account to execute filesystem operations on. - /// - /// - /// The Data Lake Store path (starting with '/') of the file on which to set or - /// remove the expiration time. - /// - /// - /// Indicates the type of expiration to use for the file: 1. NeverExpire: - /// ExpireTime is ignored. 2. RelativeToNow: ExpireTime is an integer in - /// milliseconds representing the expiration date relative to when file - /// expiration is updated. 3. RelativeToCreationDate: ExpireTime is an integer - /// in milliseconds representing the expiration date relative to file creation. - /// 4. Absolute: ExpireTime is an integer in milliseconds, as a Unix timestamp - /// relative to 1/1/1970 00:00:00. Possible values include: 'NeverExpire', - /// 'RelativeToNow', 'RelativeToCreationDate', 'Absolute' - /// - /// - /// The time that the file will expire, corresponding to the ExpiryOption that - /// was set. - /// - /// - /// The cancellation token. - /// - public static async Task SetFileExpiryAsync(this IFileSystemOperations operations, string accountName, string path, ExpiryOptionType expiryOption, long? expireTime = default(long?), CancellationToken cancellationToken = default(CancellationToken)) - { - (await operations.SetFileExpiryWithHttpMessagesAsync(accountName, path, expiryOption, expireTime, null, cancellationToken).ConfigureAwait(false)).Dispose(); - } - /// /// Checks if the specified access is available at the given path. /// diff --git a/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/IFileSystemOperations.cs b/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/IFileSystemOperations.cs index 11c134cac40e2..7aaaae91fc232 100644 --- a/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/IFileSystemOperations.cs +++ b/src/SDKs/DataLake.Store/Management.DataLake.Store/Generated/IFileSystemOperations.cs @@ -25,6 +25,48 @@ namespace Microsoft.Azure.Management.DataLake.Store /// public partial interface IFileSystemOperations { + /// + /// Sets or removes the expiration time on the specified file. This + /// operation can only be executed against files. Folders are not + /// supported. + /// + /// + /// The Azure Data Lake Store account to execute filesystem operations + /// on. + /// + /// + /// The Data Lake Store path (starting with '/') of the file on which + /// to set or remove the expiration time. + /// + /// + /// Indicates the type of expiration to use for the file: 1. + /// NeverExpire: ExpireTime is ignored. 2. RelativeToNow: ExpireTime is + /// an integer in milliseconds representing the expiration date + /// relative to when file expiration is updated. 3. + /// RelativeToCreationDate: ExpireTime is an integer in milliseconds + /// representing the expiration date relative to file creation. 4. + /// Absolute: ExpireTime is an integer in milliseconds, as a Unix + /// timestamp relative to 1/1/1970 00:00:00. Possible values include: + /// 'NeverExpire', 'RelativeToNow', 'RelativeToCreationDate', + /// 'Absolute' + /// + /// + /// The time that the file will expire, corresponding to the + /// ExpiryOption that was set. + /// + /// + /// The headers that will be added to request. + /// + /// + /// The cancellation token. + /// + /// + /// Thrown when the operation returned an invalid status code + /// + /// + /// Thrown when a required parameter is null + /// + Task SetFileExpiryWithHttpMessagesAsync(string accountName, string path, ExpiryOptionType expiryOption, long? expireTime = default(long?), Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// /// Appends to the specified file, optionally first creating the file /// if it does not yet exist. This method supports multiple concurrent @@ -78,48 +120,6 @@ public partial interface IFileSystemOperations /// Task ConcurrentAppendWithHttpMessagesAsync(string accountName, string path, Stream streamContents, AppendModeType? appendMode = default(AppendModeType?), SyncFlag? syncFlag = default(SyncFlag?), Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); /// - /// Sets or removes the expiration time on the specified file. This - /// operation can only be executed against files. Folders are not - /// supported. - /// - /// - /// The Azure Data Lake Store account to execute filesystem operations - /// on. - /// - /// - /// The Data Lake Store path (starting with '/') of the file on which - /// to set or remove the expiration time. - /// - /// - /// Indicates the type of expiration to use for the file: 1. - /// NeverExpire: ExpireTime is ignored. 2. RelativeToNow: ExpireTime is - /// an integer in milliseconds representing the expiration date - /// relative to when file expiration is updated. 3. - /// RelativeToCreationDate: ExpireTime is an integer in milliseconds - /// representing the expiration date relative to file creation. 4. - /// Absolute: ExpireTime is an integer in milliseconds, as a Unix - /// timestamp relative to 1/1/1970 00:00:00. Possible values include: - /// 'NeverExpire', 'RelativeToNow', 'RelativeToCreationDate', - /// 'Absolute' - /// - /// - /// The time that the file will expire, corresponding to the - /// ExpiryOption that was set. - /// - /// - /// The headers that will be added to request. - /// - /// - /// The cancellation token. - /// - /// - /// Thrown when the operation returned an invalid status code - /// - /// - /// Thrown when a required parameter is null - /// - Task SetFileExpiryWithHttpMessagesAsync(string accountName, string path, ExpiryOptionType expiryOption, long? expireTime = default(long?), Dictionary> customHeaders = null, CancellationToken cancellationToken = default(CancellationToken)); - /// /// Checks if the specified access is available at the given path. /// /// diff --git a/src/SDKs/DataLake.Store/Management.DataLake.Store/generate.cmd b/src/SDKs/DataLake.Store/Management.DataLake.Store/generate.cmd index 7fccf2a1e4a26..a22be0151ee63 100644 --- a/src/SDKs/DataLake.Store/Management.DataLake.Store/generate.cmd +++ b/src/SDKs/DataLake.Store/Management.DataLake.Store/generate.cmd @@ -6,8 +6,8 @@ @echo off setlocal -set accountSpecFile="https://raw.githubusercontent.com/Azure/azure-rest-api-specs/5f839ce3d1f11a3107a61375a61580ff1353b98b/specification/datalake-store/resource-manager/Microsoft.DataLakeStore/2016-11-01/account.json" -set filesystemSpecFile="https://raw.githubusercontent.com/Azure/azure-rest-api-specs/5f839ce3d1f11a3107a61375a61580ff1353b98b/specification/datalake-store/data-plane/Microsoft.DataLakeStore/2016-11-01/filesystem.json" +set accountSpecFile="https://raw.githubusercontent.com/Azure/azure-rest-api-specs/91edc3084d674ecabb105584ad926d4d8449b054/specification/datalake-store/resource-manager/Microsoft.DataLakeStore/2016-11-01/account.json" +set filesystemSpecFile="https://raw.githubusercontent.com/Azure/azure-rest-api-specs/91edc3084d674ecabb105584ad926d4d8449b054/specification/datalake-store/data-plane/Microsoft.DataLakeStore/2016-11-01/filesystem.json" set repoRoot=%~dp0..\..\..\.. set generateFolder=%~dp0Generated