diff --git a/sdk/kusto/mgmt-v2019_11_09/pom.xml b/sdk/kusto/mgmt-v2019_11_09/pom.xml
index e420ec4d8fb3c..df4782177dbb8 100644
--- a/sdk/kusto/mgmt-v2019_11_09/pom.xml
+++ b/sdk/kusto/mgmt-v2019_11_09/pom.xml
@@ -11,8 +11,8 @@
com.microsoft.azure
azure-arm-parent
- 1.2.0
- ../../parents/azure-arm-parent
+ 1.1.0
+ ../../../pom.management.xml
azure-mgmt-kusto
1.0.0-beta
diff --git a/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/ClustersImpl.java b/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/ClustersImpl.java
index 471599e4af641..5ed28ab63926e 100644
--- a/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/ClustersImpl.java
+++ b/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/ClustersImpl.java
@@ -2,7 +2,7 @@
* Copyright (c) Microsoft Corporation. All rights reserved.
* Licensed under the MIT License. See License.txt in the project root for
* license information.
- *
+ *
* Code generated by Microsoft (R) AutoRest Code Generator.
* def
*/
@@ -14,26 +14,22 @@
import com.microsoft.azure.management.kusto.v2019_11_09.Cluster;
import rx.Observable;
import rx.Completable;
-
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
-
import com.microsoft.azure.arm.resources.ResourceUtilsCore;
import com.microsoft.azure.arm.utils.RXMapper;
import rx.functions.Func1;
import com.microsoft.azure.PagedList;
import com.microsoft.azure.Page;
-
import java.util.List;
-
import com.microsoft.azure.management.kusto.v2019_11_09.FollowerDatabaseDefinition;
import com.microsoft.azure.management.kusto.v2019_11_09.DiagnoseVirtualNetworkResult;
import com.microsoft.azure.management.kusto.v2019_11_09.CheckNameResult;
import com.microsoft.azure.management.kusto.v2019_11_09.AzureResourceSku;
import com.microsoft.azure.management.kusto.v2019_11_09.SkuDescription;
-class ClustersImpl extends GroupableResourcesCoreImpl implements Clusters {
+class ClustersImpl extends GroupableResourcesCoreImpl implements Clusters {
protected ClustersImpl(KustoManager manager) {
super(manager.inner().clusters(), manager);
}
@@ -66,7 +62,7 @@ public Observable deleteByIdsAsync(Collection ids) {
}
@Override
- public Observable deleteByIdsAsync(String... ids) {
+ public Observable deleteByIdsAsync(String...ids) {
return this.deleteByIdsAsync(new ArrayList(Arrays.asList(ids)));
}
@@ -78,7 +74,7 @@ public void deleteByIds(Collection ids) {
}
@Override
- public void deleteByIds(String... ids) {
+ public void deleteByIds(String...ids) {
this.deleteByIds(new ArrayList(Arrays.asList(ids)));
}
@@ -92,18 +88,18 @@ public PagedList listByResourceGroup(String resourceGroupName) {
public Observable listByResourceGroupAsync(String resourceGroupName) {
ClustersInner client = this.inner();
return client.listByResourceGroupAsync(resourceGroupName)
- .flatMap(new Func1, Observable>() {
- @Override
- public Observable call(Page innerPage) {
- return Observable.from(innerPage.items());
- }
- })
- .map(new Func1() {
- @Override
- public Cluster call(ClusterInner inner) {
- return wrapModel(inner);
- }
- });
+ .flatMap(new Func1, Observable>() {
+ @Override
+ public Observable call(Page innerPage) {
+ return Observable.from(innerPage.items());
+ }
+ })
+ .map(new Func1() {
+ @Override
+ public Cluster call(ClusterInner inner) {
+ return wrapModel(inner);
+ }
+ });
}
@Override
@@ -116,18 +112,18 @@ public PagedList list() {
public Observable listAsync() {
ClustersInner client = this.inner();
return client.listAsync()
- .flatMap(new Func1, Observable>() {
- @Override
- public Observable call(Page innerList) {
- return Observable.from(innerList.items());
- }
- })
- .map(new Func1() {
- @Override
- public Cluster call(ClusterInner inner) {
- return wrapModel(inner);
- }
- });
+ .flatMap(new Func1, Observable>() {
+ @Override
+ public Observable call(List innerList) {
+ return Observable.from(innerList);
+ }
+ })
+ .map(new Func1() {
+ @Override
+ public Cluster call(ClusterInner inner) {
+ return wrapModel(inner);
+ }
+ });
}
@Override
@@ -151,18 +147,18 @@ public Completable startAsync(String resourceGroupName, String clusterName) {
public Observable listFollowerDatabasesAsync(String resourceGroupName, String clusterName) {
ClustersInner client = this.inner();
return client.listFollowerDatabasesAsync(resourceGroupName, clusterName)
- .flatMap(new Func1, Observable>() {
- @Override
- public Observable call(List innerList) {
- return Observable.from(innerList);
- }
- })
- .map(new Func1() {
- @Override
- public FollowerDatabaseDefinition call(FollowerDatabaseDefinitionInner inner) {
- return new FollowerDatabaseDefinitionImpl(inner, manager());
- }
- });
+ .flatMap(new Func1, Observable>() {
+ @Override
+ public Observable call(List innerList) {
+ return Observable.from(innerList);
+ }
+ })
+ .map(new Func1() {
+ @Override
+ public FollowerDatabaseDefinition call(FollowerDatabaseDefinitionInner inner) {
+ return new FollowerDatabaseDefinitionImpl(inner, manager());
+ }
+ });
}
@Override
@@ -175,17 +171,17 @@ public Completable detachFollowerDatabasesAsync(String resourceGroupName, String
public Observable diagnoseVirtualNetworkAsync(String resourceGroupName, String clusterName) {
ClustersInner client = this.inner();
return client.diagnoseVirtualNetworkAsync(resourceGroupName, clusterName)
- .map(new Func1() {
- @Override
- public DiagnoseVirtualNetworkResult call(DiagnoseVirtualNetworkResultInner inner) {
- return new DiagnoseVirtualNetworkResultImpl(inner, manager());
- }
- });
+ .map(new Func1() {
+ @Override
+ public DiagnoseVirtualNetworkResult call(DiagnoseVirtualNetworkResultInner inner) {
+ return new DiagnoseVirtualNetworkResultImpl(inner, manager());
+ }
+ });
}
@Override
protected ClusterImpl wrapModel(ClusterInner inner) {
- return new ClusterImpl(inner.name(), inner, manager());
+ return new ClusterImpl(inner.name(), inner, manager());
}
@Override
@@ -194,55 +190,55 @@ protected ClusterImpl wrapModel(String name) {
}
private AzureResourceSkuImpl wrapAzureResourceSkuModel(AzureResourceSkuInner inner) {
- return new AzureResourceSkuImpl(inner, manager());
+ return new AzureResourceSkuImpl(inner, manager());
}
@Override
public Observable checkNameAvailabilityAsync(String location, String name) {
ClustersInner client = this.inner();
return client.checkNameAvailabilityAsync(location, name)
- .map(new Func1() {
- @Override
- public CheckNameResult call(CheckNameResultInner inner) {
- return new CheckNameResultImpl(inner, manager());
- }
- });
+ .map(new Func1() {
+ @Override
+ public CheckNameResult call(CheckNameResultInner inner) {
+ return new CheckNameResultImpl(inner, manager());
+ }
+ });
}
@Override
public Observable listSkusByResourceAsync(String resourceGroupName, String clusterName) {
ClustersInner client = this.inner();
return client.listSkusByResourceAsync(resourceGroupName, clusterName)
- .flatMap(new Func1, Observable>() {
- @Override
- public Observable call(List innerList) {
- return Observable.from(innerList);
- }
- })
- .map(new Func1() {
- @Override
- public AzureResourceSku call(AzureResourceSkuInner inner) {
- return wrapAzureResourceSkuModel(inner);
- }
- });
+ .flatMap(new Func1, Observable>() {
+ @Override
+ public Observable call(List innerList) {
+ return Observable.from(innerList);
+ }
+ })
+ .map(new Func1() {
+ @Override
+ public AzureResourceSku call(AzureResourceSkuInner inner) {
+ return wrapAzureResourceSkuModel(inner);
+ }
+ });
}
@Override
public Observable listSkusAsync() {
ClustersInner client = this.inner();
return client.listSkusAsync()
- .flatMap(new Func1, Observable>() {
- @Override
- public Observable call(List innerList) {
- return Observable.from(innerList);
- }
- })
- .map(new Func1() {
- @Override
- public SkuDescription call(SkuDescriptionInner inner) {
- return new SkuDescriptionImpl(inner, manager());
- }
- });
+ .flatMap(new Func1, Observable>() {
+ @Override
+ public Observable call(List innerList) {
+ return Observable.from(innerList);
+ }
+ })
+ .map(new Func1() {
+ @Override
+ public SkuDescription call(SkuDescriptionInner inner) {
+ return new SkuDescriptionImpl(inner, manager());
+ }
+ });
}
}
diff --git a/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/ClustersInner.java b/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/ClustersInner.java
index f13acc1cb2dd2..d19d6cc5d0841 100644
--- a/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/ClustersInner.java
+++ b/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/ClustersInner.java
@@ -1552,7 +1552,6 @@ private ServiceResponse> listByResourceGroupDelegate(Resp
.build(response);
}
-
/**
* Lists all Kusto clusters within a subscription.
*
@@ -1561,16 +1560,8 @@ private ServiceResponse> listByResourceGroupDelegate(Resp
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
* @return the List<ClusterInner> object if successful.
*/
- public PagedList list() {
- PageImpl page = new PageImpl<>();
- page.setItems(listWithServiceResponseAsync().toBlocking().single().body());
- page.setNextPageLink(null);
- return new PagedList(page) {
- @Override
- public Page nextPage(String nextPageLink) {
- return null;
- }
- };
+ public List list() {
+ return listWithServiceResponseAsync().toBlocking().single().body();
}
/**
@@ -1590,12 +1581,11 @@ public ServiceFuture> listAsync(final ServiceCallback> listAsync() {
- return listWithServiceResponseAsync().map(new Func1>, Page>() {
- public Page call(ServiceResponse> response) {
- PageImpl page = new PageImpl<>();
- page.setItems(response.body());
- return page;
+ public Observable> listAsync() {
+ return listWithServiceResponseAsync().map(new Func1>, List>() {
+ @Override
+ public List call(ServiceResponse> response) {
+ return response.body();
}
});
}
diff --git a/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/DataConnectionInner.java b/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/DataConnectionInner.java
index e6d1054b5ac9b..00d2cf725966e 100644
--- a/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/DataConnectionInner.java
+++ b/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/DataConnectionInner.java
@@ -13,9 +13,6 @@
import com.fasterxml.jackson.annotation.JsonTypeName;
import com.fasterxml.jackson.annotation.JsonSubTypes;
import com.microsoft.azure.ProxyResource;
-import com.microsoft.azure.management.kusto.v2019_11_09.EventGridDataConnection;
-import com.microsoft.azure.management.kusto.v2019_11_09.EventHubDataConnection;
-import com.microsoft.azure.management.kusto.v2019_11_09.IotHubDataConnection;
/**
* Class representing an data connection.
diff --git a/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/DatabaseInner.java b/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/DatabaseInner.java
index 4ffe396fb91bd..8500768bd4d4b 100644
--- a/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/DatabaseInner.java
+++ b/sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/DatabaseInner.java
@@ -13,8 +13,6 @@
import com.fasterxml.jackson.annotation.JsonTypeName;
import com.fasterxml.jackson.annotation.JsonSubTypes;
import com.microsoft.azure.ProxyResource;
-import com.microsoft.azure.management.kusto.v2019_11_09.ReadOnlyFollowingDatabase;
-import com.microsoft.azure.management.kusto.v2019_11_09.ReadWriteDatabase;
/**
* Class representing a Kusto database.