diff --git a/services/datalake/analytics/2015-10-01-preview/catalog/version.go b/services/datalake/analytics/2015-10-01-preview/catalog/version.go index 96fb32e0dc8b..a1ab6713ecaa 100644 --- a/services/datalake/analytics/2015-10-01-preview/catalog/version.go +++ b/services/datalake/analytics/2015-10-01-preview/catalog/version.go @@ -19,10 +19,10 @@ package catalog // UserAgent returns the UserAgent string to use when sending http.Requests. func UserAgent() string { - return "Azure-SDK-For-Go/v12.1.1-beta services" + return "Azure-SDK-For-Go/v12.2.1-beta services" } // Version returns the semantic version (see http://semver.org) of the client. func Version() string { - return "v12.1.1-beta" + return "v12.2.1-beta" } diff --git a/services/datalake/analytics/2015-11-01-preview/job/version.go b/services/datalake/analytics/2015-11-01-preview/job/version.go index e313fcfe17a2..86c1327c4aef 100644 --- a/services/datalake/analytics/2015-11-01-preview/job/version.go +++ b/services/datalake/analytics/2015-11-01-preview/job/version.go @@ -19,10 +19,10 @@ package job // UserAgent returns the UserAgent string to use when sending http.Requests. func UserAgent() string { - return "Azure-SDK-For-Go/v12.1.1-beta services" + return "Azure-SDK-For-Go/v12.2.1-beta services" } // Version returns the semantic version (see http://semver.org) of the client. func Version() string { - return "v12.1.1-beta" + return "v12.2.1-beta" } diff --git a/services/datalake/analytics/2016-03-20-preview/job/version.go b/services/datalake/analytics/2016-03-20-preview/job/version.go index e313fcfe17a2..86c1327c4aef 100644 --- a/services/datalake/analytics/2016-03-20-preview/job/version.go +++ b/services/datalake/analytics/2016-03-20-preview/job/version.go @@ -19,10 +19,10 @@ package job // UserAgent returns the UserAgent string to use when sending http.Requests. func UserAgent() string { - return "Azure-SDK-For-Go/v12.1.1-beta services" + return "Azure-SDK-For-Go/v12.2.1-beta services" } // Version returns the semantic version (see http://semver.org) of the client. func Version() string { - return "v12.1.1-beta" + return "v12.2.1-beta" } diff --git a/services/datalake/analytics/2016-11-01-preview/catalog/catalog.go b/services/datalake/analytics/2016-11-01-preview/catalog/catalog.go index ea3d4b96801c..fc2a8ab04714 100644 --- a/services/datalake/analytics/2016-11-01-preview/catalog/catalog.go +++ b/services/datalake/analytics/2016-11-01-preview/catalog/catalog.go @@ -1596,7 +1596,7 @@ func (client Client) GrantACLToDatabaseResponder(resp *http.Response) (result au // values sorted, e.g. Categories?$orderby=CategoryName desc. Optional. count is the Boolean value of true or false to // request a count of the matching resources included with the resources in the response, e.g. Categories?$count=true. // Optional. -func (client Client) ListAcls(ctx context.Context, accountName string, filter string, top *int32, skip *int32, selectParameter string, orderby string, count *bool) (result ACLList, err error) { +func (client Client) ListAcls(ctx context.Context, accountName string, filter string, top *int32, skip *int32, selectParameter string, orderby string, count *bool) (result ACLListPage, err error) { if err := validation.Validate([]validation.Validation{ {TargetValue: top, Constraints: []validation.Constraint{{Target: "top", Name: validation.Null, Rule: false, @@ -1607,6 +1607,7 @@ func (client Client) ListAcls(ctx context.Context, accountName string, filter st return result, validation.NewErrorWithValidationError(err, "catalog.Client", "ListAcls") } + result.fn = client.listAclsNextResults req, err := client.ListAclsPreparer(ctx, accountName, filter, top, skip, selectParameter, orderby, count) if err != nil { err = autorest.NewErrorWithError(err, "catalog.Client", "ListAcls", nil, "Failure preparing request") @@ -1615,12 +1616,12 @@ func (client Client) ListAcls(ctx context.Context, accountName string, filter st resp, err := client.ListAclsSender(req) if err != nil { - result.Response = autorest.Response{Response: resp} + result.al.Response = autorest.Response{Response: resp} err = autorest.NewErrorWithError(err, "catalog.Client", "ListAcls", resp, "Failure sending request") return } - result, err = client.ListAclsResponder(resp) + result.al, err = client.ListAclsResponder(resp) if err != nil { err = autorest.NewErrorWithError(err, "catalog.Client", "ListAcls", resp, "Failure responding to request") } @@ -1686,6 +1687,33 @@ func (client Client) ListAclsResponder(resp *http.Response) (result ACLList, err return } +// listAclsNextResults retrieves the next set of results, if any. +func (client Client) listAclsNextResults(lastResults ACLList) (result ACLList, err error) { + req, err := lastResults.aCLListPreparer() + if err != nil { + return result, autorest.NewErrorWithError(err, "catalog.Client", "listAclsNextResults", nil, "Failure preparing next results request") + } + if req == nil { + return + } + resp, err := client.ListAclsSender(req) + if err != nil { + result.Response = autorest.Response{Response: resp} + return result, autorest.NewErrorWithError(err, "catalog.Client", "listAclsNextResults", resp, "Failure sending next results request") + } + result, err = client.ListAclsResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "catalog.Client", "listAclsNextResults", resp, "Failure responding to next results request") + } + return +} + +// ListAclsComplete enumerates all values, automatically crossing page boundaries as required. +func (client Client) ListAclsComplete(ctx context.Context, accountName string, filter string, top *int32, skip *int32, selectParameter string, orderby string, count *bool) (result ACLListIterator, err error) { + result.page, err = client.ListAcls(ctx, accountName, filter, top, skip, selectParameter, orderby, count) + return +} + // ListAclsByDatabase retrieves the list of access control list (ACL) entries for the database from the Data Lake // Analytics catalog. // @@ -1697,7 +1725,7 @@ func (client Client) ListAclsResponder(resp *http.Response) (result ACLList, err // depending on the order you'd like the values sorted, e.g. Categories?$orderby=CategoryName desc. Optional. count is // the Boolean value of true or false to request a count of the matching resources included with the resources in the // response, e.g. Categories?$count=true. Optional. -func (client Client) ListAclsByDatabase(ctx context.Context, accountName string, databaseName string, filter string, top *int32, skip *int32, selectParameter string, orderby string, count *bool) (result ACLList, err error) { +func (client Client) ListAclsByDatabase(ctx context.Context, accountName string, databaseName string, filter string, top *int32, skip *int32, selectParameter string, orderby string, count *bool) (result ACLListPage, err error) { if err := validation.Validate([]validation.Validation{ {TargetValue: top, Constraints: []validation.Constraint{{Target: "top", Name: validation.Null, Rule: false, @@ -1708,6 +1736,7 @@ func (client Client) ListAclsByDatabase(ctx context.Context, accountName string, return result, validation.NewErrorWithValidationError(err, "catalog.Client", "ListAclsByDatabase") } + result.fn = client.listAclsByDatabaseNextResults req, err := client.ListAclsByDatabasePreparer(ctx, accountName, databaseName, filter, top, skip, selectParameter, orderby, count) if err != nil { err = autorest.NewErrorWithError(err, "catalog.Client", "ListAclsByDatabase", nil, "Failure preparing request") @@ -1716,12 +1745,12 @@ func (client Client) ListAclsByDatabase(ctx context.Context, accountName string, resp, err := client.ListAclsByDatabaseSender(req) if err != nil { - result.Response = autorest.Response{Response: resp} + result.al.Response = autorest.Response{Response: resp} err = autorest.NewErrorWithError(err, "catalog.Client", "ListAclsByDatabase", resp, "Failure sending request") return } - result, err = client.ListAclsByDatabaseResponder(resp) + result.al, err = client.ListAclsByDatabaseResponder(resp) if err != nil { err = autorest.NewErrorWithError(err, "catalog.Client", "ListAclsByDatabase", resp, "Failure responding to request") } @@ -1791,6 +1820,33 @@ func (client Client) ListAclsByDatabaseResponder(resp *http.Response) (result AC return } +// listAclsByDatabaseNextResults retrieves the next set of results, if any. +func (client Client) listAclsByDatabaseNextResults(lastResults ACLList) (result ACLList, err error) { + req, err := lastResults.aCLListPreparer() + if err != nil { + return result, autorest.NewErrorWithError(err, "catalog.Client", "listAclsByDatabaseNextResults", nil, "Failure preparing next results request") + } + if req == nil { + return + } + resp, err := client.ListAclsByDatabaseSender(req) + if err != nil { + result.Response = autorest.Response{Response: resp} + return result, autorest.NewErrorWithError(err, "catalog.Client", "listAclsByDatabaseNextResults", resp, "Failure sending next results request") + } + result, err = client.ListAclsByDatabaseResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "catalog.Client", "listAclsByDatabaseNextResults", resp, "Failure responding to next results request") + } + return +} + +// ListAclsByDatabaseComplete enumerates all values, automatically crossing page boundaries as required. +func (client Client) ListAclsByDatabaseComplete(ctx context.Context, accountName string, databaseName string, filter string, top *int32, skip *int32, selectParameter string, orderby string, count *bool) (result ACLListIterator, err error) { + result.page, err = client.ListAclsByDatabase(ctx, accountName, databaseName, filter, top, skip, selectParameter, orderby, count) + return +} + // ListAssemblies retrieves the list of assemblies from the Data Lake Analytics catalog. // // accountName is the Azure Data Lake Analytics account upon which to execute catalog operations. databaseName is the diff --git a/services/datalake/analytics/2016-11-01-preview/catalog/models.go b/services/datalake/analytics/2016-11-01-preview/catalog/models.go index d87f7f2a8e06..74b7824ae610 100644 --- a/services/datalake/analytics/2016-11-01-preview/catalog/models.go +++ b/services/datalake/analytics/2016-11-01-preview/catalog/models.go @@ -104,10 +104,105 @@ type ACLDeleteParameters struct { // ACLList a Data Lake Analytics catalog access control list (ACL). type ACLList struct { autorest.Response `json:"-"` + // NextLink - the link to the next page of results. + NextLink *string `json:"nextLink,omitempty"` // Value - the access control list (ACL). Value *[]ACL `json:"value,omitempty"` } +// ACLListIterator provides access to a complete listing of ACL values. +type ACLListIterator struct { + i int + page ACLListPage +} + +// Next advances to the next value. If there was an error making +// the request the iterator does not advance and the error is returned. +func (iter *ACLListIterator) Next() error { + iter.i++ + if iter.i < len(iter.page.Values()) { + return nil + } + err := iter.page.Next() + if err != nil { + iter.i-- + return err + } + iter.i = 0 + return nil +} + +// NotDone returns true if the enumeration should be started or is not yet complete. +func (iter ACLListIterator) NotDone() bool { + return iter.page.NotDone() && iter.i < len(iter.page.Values()) +} + +// Response returns the raw server response from the last page request. +func (iter ACLListIterator) Response() ACLList { + return iter.page.Response() +} + +// Value returns the current value or a zero-initialized value if the +// iterator has advanced beyond the end of the collection. +func (iter ACLListIterator) Value() ACL { + if !iter.page.NotDone() { + return ACL{} + } + return iter.page.Values()[iter.i] +} + +// IsEmpty returns true if the ListResult contains no values. +func (al ACLList) IsEmpty() bool { + return al.Value == nil || len(*al.Value) == 0 +} + +// aCLListPreparer prepares a request to retrieve the next set of results. +// It returns nil if no more results exist. +func (al ACLList) aCLListPreparer() (*http.Request, error) { + if al.NextLink == nil || len(to.String(al.NextLink)) < 1 { + return nil, nil + } + return autorest.Prepare(&http.Request{}, + autorest.AsJSON(), + autorest.AsGet(), + autorest.WithBaseURL(to.String(al.NextLink))) +} + +// ACLListPage contains a page of ACL values. +type ACLListPage struct { + fn func(ACLList) (ACLList, error) + al ACLList +} + +// Next advances to the next page of values. If there was an error making +// the request the page does not advance and the error is returned. +func (page *ACLListPage) Next() error { + next, err := page.fn(page.al) + if err != nil { + return err + } + page.al = next + return nil +} + +// NotDone returns true if the page enumeration should be started or is not yet complete. +func (page ACLListPage) NotDone() bool { + return !page.al.IsEmpty() +} + +// Response returns the raw server response from the last page request. +func (page ACLListPage) Response() ACLList { + return page.al +} + +// Values returns the slice of values for the current page or nil if there are no values. +func (page ACLListPage) Values() []ACL { + if page.al.IsEmpty() { + return nil + } + return *page.al.Value +} + // DataLakeAnalyticsCatalogCredentialCreateParameters data Lake Analytics catalog credential creation parameters. type DataLakeAnalyticsCatalogCredentialCreateParameters struct { // Password - the password for the credential and user with access to the data source. diff --git a/services/datalake/analytics/2016-11-01-preview/catalog/version.go b/services/datalake/analytics/2016-11-01-preview/catalog/version.go index 96fb32e0dc8b..a1ab6713ecaa 100644 --- a/services/datalake/analytics/2016-11-01-preview/catalog/version.go +++ b/services/datalake/analytics/2016-11-01-preview/catalog/version.go @@ -19,10 +19,10 @@ package catalog // UserAgent returns the UserAgent string to use when sending http.Requests. func UserAgent() string { - return "Azure-SDK-For-Go/v12.1.1-beta services" + return "Azure-SDK-For-Go/v12.2.1-beta services" } // Version returns the semantic version (see http://semver.org) of the client. func Version() string { - return "v12.1.1-beta" + return "v12.2.1-beta" } diff --git a/services/datalake/analytics/2016-11-01/job/version.go b/services/datalake/analytics/2016-11-01/job/version.go index e313fcfe17a2..86c1327c4aef 100644 --- a/services/datalake/analytics/2016-11-01/job/version.go +++ b/services/datalake/analytics/2016-11-01/job/version.go @@ -19,10 +19,10 @@ package job // UserAgent returns the UserAgent string to use when sending http.Requests. func UserAgent() string { - return "Azure-SDK-For-Go/v12.1.1-beta services" + return "Azure-SDK-For-Go/v12.2.1-beta services" } // Version returns the semantic version (see http://semver.org) of the client. func Version() string { - return "v12.1.1-beta" + return "v12.2.1-beta" } diff --git a/services/datalake/analytics/2017-09-01-preview/job/models.go b/services/datalake/analytics/2017-09-01-preview/job/models.go index 50b4dce3c9ad..8267721ed29a 100644 --- a/services/datalake/analytics/2017-09-01-preview/job/models.go +++ b/services/datalake/analytics/2017-09-01-preview/job/models.go @@ -1152,22 +1152,30 @@ func (future JobCancelFuture) Result(client Client) (ar autorest.Response, err e var done bool done, err = future.Done(client) if err != nil { + err = autorest.NewErrorWithError(err, "job.JobCancelFuture", "Result", future.Response(), "Polling failure") return } if !done { - return ar, autorest.NewError("job.JobCancelFuture", "Result", "asynchronous operation has not completed") + return ar, azure.NewAsyncOpIncompleteError("job.JobCancelFuture") } if future.PollingMethod() == azure.PollingLocation { ar, err = client.CancelResponder(future.Response()) + if err != nil { + err = autorest.NewErrorWithError(err, "job.JobCancelFuture", "Result", future.Response(), "Failure responding to request") + } return } var resp *http.Response resp, err = autorest.SendWithSender(client, autorest.ChangeToGet(future.req), autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...)) if err != nil { + err = autorest.NewErrorWithError(err, "job.JobCancelFuture", "Result", resp, "Failure sending request") return } ar, err = client.CancelResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "job.JobCancelFuture", "Result", resp, "Failure responding to request") + } return } @@ -1183,22 +1191,30 @@ func (future JobUpdateFuture) Result(client Client) (i Information, err error) { var done bool done, err = future.Done(client) if err != nil { + err = autorest.NewErrorWithError(err, "job.JobUpdateFuture", "Result", future.Response(), "Polling failure") return } if !done { - return i, autorest.NewError("job.JobUpdateFuture", "Result", "asynchronous operation has not completed") + return i, azure.NewAsyncOpIncompleteError("job.JobUpdateFuture") } if future.PollingMethod() == azure.PollingLocation { i, err = client.UpdateResponder(future.Response()) + if err != nil { + err = autorest.NewErrorWithError(err, "job.JobUpdateFuture", "Result", future.Response(), "Failure responding to request") + } return } var resp *http.Response resp, err = autorest.SendWithSender(client, autorest.ChangeToGet(future.req), autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...)) if err != nil { + err = autorest.NewErrorWithError(err, "job.JobUpdateFuture", "Result", resp, "Failure sending request") return } i, err = client.UpdateResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "job.JobUpdateFuture", "Result", resp, "Failure responding to request") + } return } @@ -1214,22 +1230,30 @@ func (future JobYieldFuture) Result(client Client) (ar autorest.Response, err er var done bool done, err = future.Done(client) if err != nil { + err = autorest.NewErrorWithError(err, "job.JobYieldFuture", "Result", future.Response(), "Polling failure") return } if !done { - return ar, autorest.NewError("job.JobYieldFuture", "Result", "asynchronous operation has not completed") + return ar, azure.NewAsyncOpIncompleteError("job.JobYieldFuture") } if future.PollingMethod() == azure.PollingLocation { ar, err = client.YieldResponder(future.Response()) + if err != nil { + err = autorest.NewErrorWithError(err, "job.JobYieldFuture", "Result", future.Response(), "Failure responding to request") + } return } var resp *http.Response resp, err = autorest.SendWithSender(client, autorest.ChangeToGet(future.req), autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...)) if err != nil { + err = autorest.NewErrorWithError(err, "job.JobYieldFuture", "Result", resp, "Failure sending request") return } ar, err = client.YieldResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "job.JobYieldFuture", "Result", resp, "Failure responding to request") + } return } diff --git a/services/datalake/analytics/2017-09-01-preview/job/version.go b/services/datalake/analytics/2017-09-01-preview/job/version.go index e313fcfe17a2..86c1327c4aef 100644 --- a/services/datalake/analytics/2017-09-01-preview/job/version.go +++ b/services/datalake/analytics/2017-09-01-preview/job/version.go @@ -19,10 +19,10 @@ package job // UserAgent returns the UserAgent string to use when sending http.Requests. func UserAgent() string { - return "Azure-SDK-For-Go/v12.1.1-beta services" + return "Azure-SDK-For-Go/v12.2.1-beta services" } // Version returns the semantic version (see http://semver.org) of the client. func Version() string { - return "v12.1.1-beta" + return "v12.2.1-beta" } diff --git a/services/datalake/store/2015-10-01-preview/filesystem/filesystem.go b/services/datalake/store/2015-10-01-preview/filesystem/filesystem.go index 6f1cdd846af6..26f95e001351 100644 --- a/services/datalake/store/2015-10-01-preview/filesystem/filesystem.go +++ b/services/datalake/store/2015-10-01-preview/filesystem/filesystem.go @@ -91,6 +91,7 @@ func (client Client) AppendPreparer(ctx context.Context, accountName string, dir } preparer := autorest.CreatePreparer( + autorest.AsOctetStream(), autorest.AsPost(), autorest.WithCustomBaseURL("https://{accountName}.{adlsFileSystemDnsSuffix}", urlParameters), autorest.WithPathParameters("/webhdfs/v1/{directFilePath}", pathParameters), @@ -326,6 +327,7 @@ func (client Client) ConcurrentAppendPreparer(ctx context.Context, accountName s } preparer := autorest.CreatePreparer( + autorest.AsOctetStream(), autorest.AsPost(), autorest.WithCustomBaseURL("https://{accountName}.{adlsFileSystemDnsSuffix}", urlParameters), autorest.WithPathParameters("/WebHdfsExt/{filePath}", pathParameters), @@ -406,13 +408,14 @@ func (client Client) CreatePreparer(ctx context.Context, accountName string, dir } preparer := autorest.CreatePreparer( + autorest.AsOctetStream(), autorest.AsPut(), autorest.WithCustomBaseURL("https://{accountName}.{adlsFileSystemDnsSuffix}", urlParameters), autorest.WithPathParameters("/webhdfs/v1/{directFilePath}", pathParameters), autorest.WithQueryParameters(queryParameters)) if streamContents != nil { preparer = autorest.DecoratePreparer(preparer, - autorest.WithJSON(streamContents)) + autorest.WithFile(streamContents)) } return preparer.Prepare((&http.Request{}).WithContext(ctx)) } @@ -1086,6 +1089,7 @@ func (client Client) MsConcatPreparer(ctx context.Context, accountName string, m } preparer := autorest.CreatePreparer( + autorest.AsOctetStream(), autorest.AsPost(), autorest.WithCustomBaseURL("https://{accountName}.{adlsFileSystemDnsSuffix}", urlParameters), autorest.WithPathParameters("/webhdfs/v1/{msConcatDestinationPath}", pathParameters), diff --git a/services/datalake/store/2015-10-01-preview/filesystem/version.go b/services/datalake/store/2015-10-01-preview/filesystem/version.go index d28a5d1e2043..e9ce38ca067b 100644 --- a/services/datalake/store/2015-10-01-preview/filesystem/version.go +++ b/services/datalake/store/2015-10-01-preview/filesystem/version.go @@ -19,10 +19,10 @@ package filesystem // UserAgent returns the UserAgent string to use when sending http.Requests. func UserAgent() string { - return "Azure-SDK-For-Go/v12.1.1-beta services" + return "Azure-SDK-For-Go/v12.2.1-beta services" } // Version returns the semantic version (see http://semver.org) of the client. func Version() string { - return "v12.1.1-beta" + return "v12.2.1-beta" } diff --git a/services/datalake/store/2016-11-01/filesystem/filesystem.go b/services/datalake/store/2016-11-01/filesystem/filesystem.go index 2caae86f77c7..2b9d2aa482bc 100644 --- a/services/datalake/store/2016-11-01/filesystem/filesystem.go +++ b/services/datalake/store/2016-11-01/filesystem/filesystem.go @@ -110,6 +110,7 @@ func (client Client) AppendPreparer(ctx context.Context, accountName string, pat } preparer := autorest.CreatePreparer( + autorest.AsOctetStream(), autorest.AsPost(), autorest.WithCustomBaseURL("https://{accountName}.{adlsFileSystemDnsSuffix}", urlParameters), autorest.WithPathParameters("/webhdfs/v1/{path}", pathParameters), @@ -351,6 +352,7 @@ func (client Client) ConcurrentAppendPreparer(ctx context.Context, accountName s } preparer := autorest.CreatePreparer( + autorest.AsOctetStream(), autorest.AsPost(), autorest.WithCustomBaseURL("https://{accountName}.{adlsFileSystemDnsSuffix}", urlParameters), autorest.WithPathParameters("/WebHdfsExt/{path}", pathParameters), @@ -450,13 +452,14 @@ func (client Client) CreatePreparer(ctx context.Context, accountName string, pat } preparer := autorest.CreatePreparer( + autorest.AsOctetStream(), autorest.AsPut(), autorest.WithCustomBaseURL("https://{accountName}.{adlsFileSystemDnsSuffix}", urlParameters), autorest.WithPathParameters("/webhdfs/v1/{path}", pathParameters), autorest.WithQueryParameters(queryParameters)) if streamContents != nil { preparer = autorest.DecoratePreparer(preparer, - autorest.WithJSON(streamContents)) + autorest.WithFile(streamContents)) } return preparer.Prepare((&http.Request{}).WithContext(ctx)) } @@ -1074,6 +1077,7 @@ func (client Client) MsConcatPreparer(ctx context.Context, accountName string, p } preparer := autorest.CreatePreparer( + autorest.AsOctetStream(), autorest.AsPost(), autorest.WithCustomBaseURL("https://{accountName}.{adlsFileSystemDnsSuffix}", urlParameters), autorest.WithPathParameters("/webhdfs/v1/{path}", pathParameters), diff --git a/services/datalake/store/2016-11-01/filesystem/models.go b/services/datalake/store/2016-11-01/filesystem/models.go index d2a62c823e01..7301fec12653 100644 --- a/services/datalake/store/2016-11-01/filesystem/models.go +++ b/services/datalake/store/2016-11-01/filesystem/models.go @@ -1179,8 +1179,6 @@ type FileStatusProperties struct { AccessTime *int64 `json:"accessTime,omitempty"` // BlockSize - the block size for the file. BlockSize *int64 `json:"blockSize,omitempty"` - // ChildrenNum - the number of children in the directory. - ChildrenNum *int64 `json:"childrenNum,omitempty"` // ExpirationTime - Gets the expiration time, if any, as ticks since the epoch. If the value is 0 or DateTime.MaxValue there is no expiration. ExpirationTime *int64 `json:"msExpirationTime,omitempty"` // Group - the group owner. diff --git a/services/datalake/store/2016-11-01/filesystem/version.go b/services/datalake/store/2016-11-01/filesystem/version.go index d28a5d1e2043..e9ce38ca067b 100644 --- a/services/datalake/store/2016-11-01/filesystem/version.go +++ b/services/datalake/store/2016-11-01/filesystem/version.go @@ -19,10 +19,10 @@ package filesystem // UserAgent returns the UserAgent string to use when sending http.Requests. func UserAgent() string { - return "Azure-SDK-For-Go/v12.1.1-beta services" + return "Azure-SDK-For-Go/v12.2.1-beta services" } // Version returns the semantic version (see http://semver.org) of the client. func Version() string { - return "v12.1.1-beta" + return "v12.2.1-beta" }