Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion sdk/kusto/mgmt-v2019_05_15/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
<parent>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-arm-parent</artifactId>
<version>1.2.0</version>
<version>1.1.0</version>
<relativePath>../../../pom.management.xml</relativePath>
</parent>
<artifactId>azure-mgmt-kusto</artifactId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,9 @@ public final class DataFormat extends ExpandableStringEnum<DataFormat> {
/** Static value AVRO for DataFormat. */
public static final DataFormat AVRO = fromString("AVRO");

/** Static value TSVE for DataFormat. */
public static final DataFormat TSVE = fromString("TSVE");

/**
* Creates or finds a DataFormat from its string representation.
* @param name a name to look for
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,8 @@ public class EventGridDataConnection extends DataConnectionInner {
/**
* The data format of the message. Optionally the data format can be added
* to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV',
* 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO'.
* 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO',
* 'TSVE'.
*/
@JsonProperty(value = "properties.dataFormat", required = true)
private DataFormat dataFormat;
Expand Down Expand Up @@ -162,7 +163,7 @@ public EventGridDataConnection withMappingRuleName(String mappingRuleName) {
}

/**
* Get the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO'.
* Get the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO', 'TSVE'.
*
* @return the dataFormat value
*/
Expand All @@ -171,7 +172,7 @@ public DataFormat dataFormat() {
}

/**
* Set the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO'.
* Set the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO', 'TSVE'.
*
* @param dataFormat the dataFormat value to set
* @return the EventGridDataConnection object itself.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,8 @@ public class EventHubDataConnection extends DataConnectionInner {
/**
* The data format of the message. Optionally the data format can be added
* to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV',
* 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO'.
* 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO',
* 'TSVE'.
*/
@JsonProperty(value = "properties.dataFormat")
private DataFormat dataFormat;
Expand Down Expand Up @@ -143,7 +144,7 @@ public EventHubDataConnection withMappingRuleName(String mappingRuleName) {
}

/**
* Get the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO'.
* Get the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO', 'TSVE'.
*
* @return the dataFormat value
*/
Expand All @@ -152,7 +153,7 @@ public DataFormat dataFormat() {
}

/**
* Set the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO'.
* Set the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO', 'TSVE'.
*
* @param dataFormat the dataFormat value to set
* @return the EventHubDataConnection object itself.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,8 @@ public class IotHubDataConnection extends DataConnectionInner {
/**
* The data format of the message. Optionally the data format can be added
* to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV',
* 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO'.
* 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO',
* 'TSVE'.
*/
@JsonProperty(value = "properties.dataFormat")
private DataFormat dataFormat;
Expand Down Expand Up @@ -149,7 +150,7 @@ public IotHubDataConnection withMappingRuleName(String mappingRuleName) {
}

/**
* Get the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO'.
* Get the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO', 'TSVE'.
*
* @return the dataFormat value
*/
Expand All @@ -158,7 +159,7 @@ public DataFormat dataFormat() {
}

/**
* Set the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO'.
* Set the data format of the message. Optionally the data format can be added to each message. Possible values include: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO', 'TSVE'.
*
* @param dataFormat the dataFormat value to set
* @return the IotHubDataConnection object itself.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -110,18 +110,18 @@ public PagedList<Cluster> list() {
public Observable<Cluster> listAsync() {
ClustersInner client = this.inner();
return client.listAsync()
.flatMap(new Func1<Page<ClusterInner>, Observable<ClusterInner>>() {
@Override
public Observable<ClusterInner> call(Page<ClusterInner> innerList) {
return Observable.from(innerList.items());
}
})
.map(new Func1<ClusterInner, Cluster>() {
@Override
public Cluster call(ClusterInner inner) {
return wrapModel(inner);
}
});
.flatMap(new Func1<List<ClusterInner>, Observable<ClusterInner>>() {
@Override
public Observable<ClusterInner> call(List<ClusterInner> innerList) {
return Observable.from(innerList);
}
})
.map(new Func1<ClusterInner, Cluster>() {
@Override
public Cluster call(ClusterInner inner) {
return wrapModel(inner);
}
});
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1120,16 +1120,8 @@ private ServiceResponse<PageImpl<ClusterInner>> listByResourceGroupDelegate(Resp
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
* @return the List&lt;ClusterInner&gt; object if successful.
*/
public PagedList<ClusterInner> list() {
PageImpl<ClusterInner> page = new PageImpl<>();
page.setItems(listWithServiceResponseAsync().toBlocking().single().body());
page.setNextPageLink(null);
return new PagedList<ClusterInner>(page) {
@Override
public Page<ClusterInner> nextPage(String nextPageLink) {
return null;
}
};
public List<ClusterInner> list() {
return listWithServiceResponseAsync().toBlocking().single().body();
}

/**
Expand All @@ -1149,13 +1141,11 @@ public ServiceFuture<List<ClusterInner>> listAsync(final ServiceCallback<List<Cl
* @throws IllegalArgumentException thrown if parameters fail the validation
* @return the observable to the List&lt;ClusterInner&gt; object
*/
public Observable<Page<ClusterInner>> listAsync() {
return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<ClusterInner>>, Page<ClusterInner>>() {
public Observable<List<ClusterInner>> listAsync() {
return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<ClusterInner>>, List<ClusterInner>>() {
@Override
public Page<ClusterInner> call(ServiceResponse<List<ClusterInner>> response) {
PageImpl<ClusterInner> page = new PageImpl<>();
page.setItems(response.body());
return page;
public List<ClusterInner> call(ServiceResponse<List<ClusterInner>> response) {
return response.body();
}
});
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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_05_15.EventGridDataConnection;
import com.microsoft.azure.management.kusto.v2019_05_15.EventHubDataConnection;
import com.microsoft.azure.management.kusto.v2019_05_15.IotHubDataConnection;

/**
* Class representing an data connection.
Expand Down