Skip to content

Commit 03e8ff3

Browse files
author
SDK Automation
committed
Generated from e032abe91d6f8e68d4c978ee432e3ad48ef70d5b
Kusto: update java readme
1 parent 3c41791 commit 03e8ff3

File tree

5 files changed

+87
-106
lines changed

5 files changed

+87
-106
lines changed

‎sdk/kusto/mgmt-v2019_11_09/pom.xml‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,8 @@
1111
<parent>
1212
<groupId>com.microsoft.azure</groupId>
1313
<artifactId>azure-arm-parent</artifactId>
14-
<version>1.2.0</version>
15-
<relativePath>../../parents/azure-arm-parent</relativePath>
14+
<version>1.1.0</version>
15+
<relativePath>../../../pom.management.xml</relativePath>
1616
</parent>
1717
<artifactId>azure-mgmt-kusto</artifactId>
1818
<version>1.0.0-beta</version>

‎sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/ClustersImpl.java‎

Lines changed: 78 additions & 82 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
* Copyright (c) Microsoft Corporation. All rights reserved.
33
* Licensed under the MIT License. See License.txt in the project root for
44
* license information.
5-
* <p>
5+
*
66
* Code generated by Microsoft (R) AutoRest Code Generator.
77
* def
88
*/
@@ -14,26 +14,22 @@
1414
import com.microsoft.azure.management.kusto.v2019_11_09.Cluster;
1515
import rx.Observable;
1616
import rx.Completable;
17-
1817
import java.util.ArrayList;
1918
import java.util.Arrays;
2019
import java.util.Collection;
21-
2220
import com.microsoft.azure.arm.resources.ResourceUtilsCore;
2321
import com.microsoft.azure.arm.utils.RXMapper;
2422
import rx.functions.Func1;
2523
import com.microsoft.azure.PagedList;
2624
import com.microsoft.azure.Page;
27-
2825
import java.util.List;
29-
3026
import com.microsoft.azure.management.kusto.v2019_11_09.FollowerDatabaseDefinition;
3127
import com.microsoft.azure.management.kusto.v2019_11_09.DiagnoseVirtualNetworkResult;
3228
import com.microsoft.azure.management.kusto.v2019_11_09.CheckNameResult;
3329
import com.microsoft.azure.management.kusto.v2019_11_09.AzureResourceSku;
3430
import com.microsoft.azure.management.kusto.v2019_11_09.SkuDescription;
3531

36-
class ClustersImpl extends GroupableResourcesCoreImpl<Cluster, ClusterImpl, ClusterInner, ClustersInner, KustoManager> implements Clusters {
32+
class ClustersImpl extends GroupableResourcesCoreImpl<Cluster, ClusterImpl, ClusterInner, ClustersInner, KustoManager> implements Clusters {
3733
protected ClustersImpl(KustoManager manager) {
3834
super(manager.inner().clusters(), manager);
3935
}
@@ -66,7 +62,7 @@ public Observable<String> deleteByIdsAsync(Collection<String> ids) {
6662
}
6763

6864
@Override
69-
public Observable<String> deleteByIdsAsync(String... ids) {
65+
public Observable<String> deleteByIdsAsync(String...ids) {
7066
return this.deleteByIdsAsync(new ArrayList<String>(Arrays.asList(ids)));
7167
}
7268

@@ -78,7 +74,7 @@ public void deleteByIds(Collection<String> ids) {
7874
}
7975

8076
@Override
81-
public void deleteByIds(String... ids) {
77+
public void deleteByIds(String...ids) {
8278
this.deleteByIds(new ArrayList<String>(Arrays.asList(ids)));
8379
}
8480

@@ -92,18 +88,18 @@ public PagedList<Cluster> listByResourceGroup(String resourceGroupName) {
9288
public Observable<Cluster> listByResourceGroupAsync(String resourceGroupName) {
9389
ClustersInner client = this.inner();
9490
return client.listByResourceGroupAsync(resourceGroupName)
95-
.flatMap(new Func1<Page<ClusterInner>, Observable<ClusterInner>>() {
96-
@Override
97-
public Observable<ClusterInner> call(Page<ClusterInner> innerPage) {
98-
return Observable.from(innerPage.items());
99-
}
100-
})
101-
.map(new Func1<ClusterInner, Cluster>() {
102-
@Override
103-
public Cluster call(ClusterInner inner) {
104-
return wrapModel(inner);
105-
}
106-
});
91+
.flatMap(new Func1<Page<ClusterInner>, Observable<ClusterInner>>() {
92+
@Override
93+
public Observable<ClusterInner> call(Page<ClusterInner> innerPage) {
94+
return Observable.from(innerPage.items());
95+
}
96+
})
97+
.map(new Func1<ClusterInner, Cluster>() {
98+
@Override
99+
public Cluster call(ClusterInner inner) {
100+
return wrapModel(inner);
101+
}
102+
});
107103
}
108104

109105
@Override
@@ -116,18 +112,18 @@ public PagedList<Cluster> list() {
116112
public Observable<Cluster> listAsync() {
117113
ClustersInner client = this.inner();
118114
return client.listAsync()
119-
.flatMap(new Func1<Page<ClusterInner>, Observable<ClusterInner>>() {
120-
@Override
121-
public Observable<ClusterInner> call(Page<ClusterInner> innerList) {
122-
return Observable.from(innerList.items());
123-
}
124-
})
125-
.map(new Func1<ClusterInner, Cluster>() {
126-
@Override
127-
public Cluster call(ClusterInner inner) {
128-
return wrapModel(inner);
129-
}
130-
});
115+
.flatMap(new Func1<List<ClusterInner>, Observable<ClusterInner>>() {
116+
@Override
117+
public Observable<ClusterInner> call(List<ClusterInner> innerList) {
118+
return Observable.from(innerList);
119+
}
120+
})
121+
.map(new Func1<ClusterInner, Cluster>() {
122+
@Override
123+
public Cluster call(ClusterInner inner) {
124+
return wrapModel(inner);
125+
}
126+
});
131127
}
132128

133129
@Override
@@ -151,18 +147,18 @@ public Completable startAsync(String resourceGroupName, String clusterName) {
151147
public Observable<FollowerDatabaseDefinition> listFollowerDatabasesAsync(String resourceGroupName, String clusterName) {
152148
ClustersInner client = this.inner();
153149
return client.listFollowerDatabasesAsync(resourceGroupName, clusterName)
154-
.flatMap(new Func1<List<FollowerDatabaseDefinitionInner>, Observable<FollowerDatabaseDefinitionInner>>() {
155-
@Override
156-
public Observable<FollowerDatabaseDefinitionInner> call(List<FollowerDatabaseDefinitionInner> innerList) {
157-
return Observable.from(innerList);
158-
}
159-
})
160-
.map(new Func1<FollowerDatabaseDefinitionInner, FollowerDatabaseDefinition>() {
161-
@Override
162-
public FollowerDatabaseDefinition call(FollowerDatabaseDefinitionInner inner) {
163-
return new FollowerDatabaseDefinitionImpl(inner, manager());
164-
}
165-
});
150+
.flatMap(new Func1<List<FollowerDatabaseDefinitionInner>, Observable<FollowerDatabaseDefinitionInner>>() {
151+
@Override
152+
public Observable<FollowerDatabaseDefinitionInner> call(List<FollowerDatabaseDefinitionInner> innerList) {
153+
return Observable.from(innerList);
154+
}
155+
})
156+
.map(new Func1<FollowerDatabaseDefinitionInner, FollowerDatabaseDefinition>() {
157+
@Override
158+
public FollowerDatabaseDefinition call(FollowerDatabaseDefinitionInner inner) {
159+
return new FollowerDatabaseDefinitionImpl(inner, manager());
160+
}
161+
});
166162
}
167163

168164
@Override
@@ -175,17 +171,17 @@ public Completable detachFollowerDatabasesAsync(String resourceGroupName, String
175171
public Observable<DiagnoseVirtualNetworkResult> diagnoseVirtualNetworkAsync(String resourceGroupName, String clusterName) {
176172
ClustersInner client = this.inner();
177173
return client.diagnoseVirtualNetworkAsync(resourceGroupName, clusterName)
178-
.map(new Func1<DiagnoseVirtualNetworkResultInner, DiagnoseVirtualNetworkResult>() {
179-
@Override
180-
public DiagnoseVirtualNetworkResult call(DiagnoseVirtualNetworkResultInner inner) {
181-
return new DiagnoseVirtualNetworkResultImpl(inner, manager());
182-
}
183-
});
174+
.map(new Func1<DiagnoseVirtualNetworkResultInner, DiagnoseVirtualNetworkResult>() {
175+
@Override
176+
public DiagnoseVirtualNetworkResult call(DiagnoseVirtualNetworkResultInner inner) {
177+
return new DiagnoseVirtualNetworkResultImpl(inner, manager());
178+
}
179+
});
184180
}
185181

186182
@Override
187183
protected ClusterImpl wrapModel(ClusterInner inner) {
188-
return new ClusterImpl(inner.name(), inner, manager());
184+
return new ClusterImpl(inner.name(), inner, manager());
189185
}
190186

191187
@Override
@@ -194,55 +190,55 @@ protected ClusterImpl wrapModel(String name) {
194190
}
195191

196192
private AzureResourceSkuImpl wrapAzureResourceSkuModel(AzureResourceSkuInner inner) {
197-
return new AzureResourceSkuImpl(inner, manager());
193+
return new AzureResourceSkuImpl(inner, manager());
198194
}
199195

200196
@Override
201197
public Observable<CheckNameResult> checkNameAvailabilityAsync(String location, String name) {
202198
ClustersInner client = this.inner();
203199
return client.checkNameAvailabilityAsync(location, name)
204-
.map(new Func1<CheckNameResultInner, CheckNameResult>() {
205-
@Override
206-
public CheckNameResult call(CheckNameResultInner inner) {
207-
return new CheckNameResultImpl(inner, manager());
208-
}
209-
});
200+
.map(new Func1<CheckNameResultInner, CheckNameResult>() {
201+
@Override
202+
public CheckNameResult call(CheckNameResultInner inner) {
203+
return new CheckNameResultImpl(inner, manager());
204+
}
205+
});
210206
}
211207

212208
@Override
213209
public Observable<AzureResourceSku> listSkusByResourceAsync(String resourceGroupName, String clusterName) {
214210
ClustersInner client = this.inner();
215211
return client.listSkusByResourceAsync(resourceGroupName, clusterName)
216-
.flatMap(new Func1<List<AzureResourceSkuInner>, Observable<AzureResourceSkuInner>>() {
217-
@Override
218-
public Observable<AzureResourceSkuInner> call(List<AzureResourceSkuInner> innerList) {
219-
return Observable.from(innerList);
220-
}
221-
})
222-
.map(new Func1<AzureResourceSkuInner, AzureResourceSku>() {
223-
@Override
224-
public AzureResourceSku call(AzureResourceSkuInner inner) {
225-
return wrapAzureResourceSkuModel(inner);
226-
}
227-
});
212+
.flatMap(new Func1<List<AzureResourceSkuInner>, Observable<AzureResourceSkuInner>>() {
213+
@Override
214+
public Observable<AzureResourceSkuInner> call(List<AzureResourceSkuInner> innerList) {
215+
return Observable.from(innerList);
216+
}
217+
})
218+
.map(new Func1<AzureResourceSkuInner, AzureResourceSku>() {
219+
@Override
220+
public AzureResourceSku call(AzureResourceSkuInner inner) {
221+
return wrapAzureResourceSkuModel(inner);
222+
}
223+
});
228224
}
229225

230226
@Override
231227
public Observable<SkuDescription> listSkusAsync() {
232228
ClustersInner client = this.inner();
233229
return client.listSkusAsync()
234-
.flatMap(new Func1<List<SkuDescriptionInner>, Observable<SkuDescriptionInner>>() {
235-
@Override
236-
public Observable<SkuDescriptionInner> call(List<SkuDescriptionInner> innerList) {
237-
return Observable.from(innerList);
238-
}
239-
})
240-
.map(new Func1<SkuDescriptionInner, SkuDescription>() {
241-
@Override
242-
public SkuDescription call(SkuDescriptionInner inner) {
243-
return new SkuDescriptionImpl(inner, manager());
244-
}
245-
});
230+
.flatMap(new Func1<List<SkuDescriptionInner>, Observable<SkuDescriptionInner>>() {
231+
@Override
232+
public Observable<SkuDescriptionInner> call(List<SkuDescriptionInner> innerList) {
233+
return Observable.from(innerList);
234+
}
235+
})
236+
.map(new Func1<SkuDescriptionInner, SkuDescription>() {
237+
@Override
238+
public SkuDescription call(SkuDescriptionInner inner) {
239+
return new SkuDescriptionImpl(inner, manager());
240+
}
241+
});
246242
}
247243

248244
}

‎sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/ClustersInner.java‎

Lines changed: 7 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -1552,7 +1552,6 @@ private ServiceResponse<PageImpl<ClusterInner>> listByResourceGroupDelegate(Resp
15521552
.build(response);
15531553
}
15541554

1555-
15561555
/**
15571556
* Lists all Kusto clusters within a subscription.
15581557
*
@@ -1561,16 +1560,8 @@ private ServiceResponse<PageImpl<ClusterInner>> listByResourceGroupDelegate(Resp
15611560
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
15621561
* @return the List&lt;ClusterInner&gt; object if successful.
15631562
*/
1564-
public PagedList<ClusterInner> list() {
1565-
PageImpl<ClusterInner> page = new PageImpl<>();
1566-
page.setItems(listWithServiceResponseAsync().toBlocking().single().body());
1567-
page.setNextPageLink(null);
1568-
return new PagedList<ClusterInner>(page) {
1569-
@Override
1570-
public Page<ClusterInner> nextPage(String nextPageLink) {
1571-
return null;
1572-
}
1573-
};
1563+
public List<ClusterInner> list() {
1564+
return listWithServiceResponseAsync().toBlocking().single().body();
15741565
}
15751566

15761567
/**
@@ -1590,12 +1581,11 @@ public ServiceFuture<List<ClusterInner>> listAsync(final ServiceCallback<List<Cl
15901581
* @throws IllegalArgumentException thrown if parameters fail the validation
15911582
* @return the observable to the List&lt;ClusterInner&gt; object
15921583
*/
1593-
public Observable<Page<ClusterInner>> listAsync() {
1594-
return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<ClusterInner>>, Page<ClusterInner>>() {
1595-
public Page<ClusterInner> call(ServiceResponse<List<ClusterInner>> response) {
1596-
PageImpl<ClusterInner> page = new PageImpl<>();
1597-
page.setItems(response.body());
1598-
return page;
1584+
public Observable<List<ClusterInner>> listAsync() {
1585+
return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<ClusterInner>>, List<ClusterInner>>() {
1586+
@Override
1587+
public List<ClusterInner> call(ServiceResponse<List<ClusterInner>> response) {
1588+
return response.body();
15991589
}
16001590
});
16011591
}

‎sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/DataConnectionInner.java‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,9 +13,6 @@
1313
import com.fasterxml.jackson.annotation.JsonTypeName;
1414
import com.fasterxml.jackson.annotation.JsonSubTypes;
1515
import com.microsoft.azure.ProxyResource;
16-
import com.microsoft.azure.management.kusto.v2019_11_09.EventGridDataConnection;
17-
import com.microsoft.azure.management.kusto.v2019_11_09.EventHubDataConnection;
18-
import com.microsoft.azure.management.kusto.v2019_11_09.IotHubDataConnection;
1916

2017
/**
2118
* Class representing an data connection.

‎sdk/kusto/mgmt-v2019_11_09/src/main/java/com/microsoft/azure/management/kusto/v2019_11_09/implementation/DatabaseInner.java‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,6 @@
1313
import com.fasterxml.jackson.annotation.JsonTypeName;
1414
import com.fasterxml.jackson.annotation.JsonSubTypes;
1515
import com.microsoft.azure.ProxyResource;
16-
import com.microsoft.azure.management.kusto.v2019_11_09.ReadOnlyFollowingDatabase;
17-
import com.microsoft.azure.management.kusto.v2019_11_09.ReadWriteDatabase;
1816

1917
/**
2018
* Class representing a Kusto database.

0 commit comments

Comments
 (0)