From a6204f287089478f3b85e243f9bf886a1d0f2859 Mon Sep 17 00:00:00 2001 From: Azure SDK for Python bot Date: Tue, 30 Jan 2018 19:01:08 +0000 Subject: [PATCH] Generated from d3af35e544597c1af44ceae46b86524b86d548e8 [ADLA - ADLS] - Adding pageable extension for Catalog ACL APIs and removing childrenNum property (#2353) * Adding paging for ListAcls and ListAclsByDatabase * Although paging is not supported for these operations, the design decision that we took was to provide support at the client side just in case we need to add it from the server side. * Removing default response from Swagger for Acl APIs * Removing childrenNum property from FileStatusProperties * This property is always null as brought up by this issue: https://github.com/Azure/azure-sdk-for-net/issues/3770 * Fixing examples for childrenNum * Fixing oav validate-example errors --- .../2015-10-01-preview/catalog/version.go | 4 +- .../2015-11-01-preview/job/version.go | 4 +- .../2016-03-20-preview/job/version.go | 4 +- .../2016-11-01-preview/catalog/catalog.go | 68 +++++++++++-- .../2016-11-01-preview/catalog/models.go | 95 +++++++++++++++++++ .../2016-11-01-preview/catalog/version.go | 4 +- .../analytics/2016-11-01/job/version.go | 4 +- .../2017-09-01-preview/job/models.go | 30 +++++- .../2017-09-01-preview/job/version.go | 4 +- .../filesystem/filesystem.go | 6 +- .../2015-10-01-preview/filesystem/version.go | 4 +- .../store/2016-11-01/filesystem/filesystem.go | 6 +- .../store/2016-11-01/filesystem/models.go | 2 - .../store/2016-11-01/filesystem/version.go | 4 +- 14 files changed, 210 insertions(+), 29 deletions(-) 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" }