From 449e8ec8988d35760fd0f4f647b13c11030ec4aa Mon Sep 17 00:00:00 2001 From: Azure SDK for Python bot Date: Mon, 3 Dec 2018 07:49:21 +0000 Subject: [PATCH 1/3] Generated from aded924bcbec0926d1f273fdc99b3a8d2d51246b Adding refresh and get IntegrationRuntimeObjectMetadata API --- .../GetSsisObjectMetadataRequest.java | 43 ++ .../IntegrationRuntimeObjectMetadatas.java | 42 ++ .../v2018_06_01/SsisObjectMetadata.java | 99 ++++ .../SsisObjectMetadataListResponse.java | 31 ++ .../v2018_06_01/SsisObjectMetadataType.java | 47 ++ .../DataFactoryManagementClientImpl.java | 14 + .../implementation/DataFactoryManager.java | 12 + ...IntegrationRuntimeObjectMetadatasImpl.java | 49 ++ ...ntegrationRuntimeObjectMetadatasInner.java | 429 ++++++++++++++++++ .../SsisObjectMetadataListResponseImpl.java | 38 ++ .../SsisObjectMetadataListResponseInner.java | 71 +++ 11 files changed, 875 insertions(+) create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/GetSsisObjectMetadataRequest.java create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadata.java create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataListResponse.java create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataType.java create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasImpl.java create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataListResponseImpl.java create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataListResponseInner.java diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/GetSsisObjectMetadataRequest.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/GetSsisObjectMetadataRequest.java new file mode 100644 index 000000000000..bb8fff41ab32 --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/GetSsisObjectMetadataRequest.java @@ -0,0 +1,43 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * The request payload of get ssis object metadata. + */ +public class GetSsisObjectMetadataRequest { + /** + * Metadata path. + */ + @JsonProperty(value = "metadataPath") + private String metadataPath; + + /** + * Get metadata path. + * + * @return the metadataPath value + */ + public String metadataPath() { + return this.metadataPath; + } + + /** + * Set metadata path. + * + * @param metadataPath the metadataPath value to set + * @return the GetSsisObjectMetadataRequest object itself. + */ + public GetSsisObjectMetadataRequest withMetadataPath(String metadataPath) { + this.metadataPath = metadataPath; + return this; + } + +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java new file mode 100644 index 000000000000..d1beea36af87 --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java @@ -0,0 +1,42 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01; + +import rx.Completable; +import rx.Observable; +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation.IntegrationRuntimeObjectMetadatasInner; +import com.microsoft.azure.arm.model.HasInner; + +/** + * Type representing IntegrationRuntimeObjectMetadatas. + */ +public interface IntegrationRuntimeObjectMetadatas extends HasInner { + /** + * Refresh a ssis integration runtime object metadata. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + Completable refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName); + + /** + * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + Observable getAsync(String resourceGroupName, String factoryName, String integrationRuntimeName); + +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadata.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadata.java new file mode 100644 index 000000000000..a1137e11dac3 --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadata.java @@ -0,0 +1,99 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01; + +import com.fasterxml.jackson.annotation.JsonProperty; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import com.fasterxml.jackson.annotation.JsonTypeName; + +/** + * Ssis object metadata. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") +@JsonTypeName("SsisObjectMetadata") +public class SsisObjectMetadata { + /** + * Metadata id. + */ + @JsonProperty(value = "id") + private Long id; + + /** + * Metadata name. + */ + @JsonProperty(value = "name") + private String name; + + /** + * Metadata description. + */ + @JsonProperty(value = "description") + private String description; + + /** + * Get metadata id. + * + * @return the id value + */ + public Long id() { + return this.id; + } + + /** + * Set metadata id. + * + * @param id the id value to set + * @return the SsisObjectMetadata object itself. + */ + public SsisObjectMetadata withId(Long id) { + this.id = id; + return this; + } + + /** + * Get metadata name. + * + * @return the name value + */ + public String name() { + return this.name; + } + + /** + * Set metadata name. + * + * @param name the name value to set + * @return the SsisObjectMetadata object itself. + */ + public SsisObjectMetadata withName(String name) { + this.name = name; + return this; + } + + /** + * Get metadata description. + * + * @return the description value + */ + public String description() { + return this.description; + } + + /** + * Set metadata description. + * + * @param description the description value to set + * @return the SsisObjectMetadata object itself. + */ + public SsisObjectMetadata withDescription(String description) { + this.description = description; + return this; + } + +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataListResponse.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataListResponse.java new file mode 100644 index 000000000000..25d8c92ef5ae --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataListResponse.java @@ -0,0 +1,31 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01; + +import com.microsoft.azure.arm.model.HasInner; +import com.microsoft.azure.arm.resources.models.HasManager; +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation.DataFactoryManager; +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation.SsisObjectMetadataListResponseInner; +import java.util.List; + +/** + * Type representing SsisObjectMetadataListResponse. + */ +public interface SsisObjectMetadataListResponse extends HasInner, HasManager { + /** + * @return the nextLink value. + */ + String nextLink(); + + /** + * @return the value value. + */ + List value(); + +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataType.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataType.java new file mode 100644 index 000000000000..99b957cc579d --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataType.java @@ -0,0 +1,47 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01; + +import java.util.Collection; +import com.fasterxml.jackson.annotation.JsonCreator; +import com.microsoft.rest.ExpandableStringEnum; + +/** + * Defines values for SsisObjectMetadataType. + */ +public final class SsisObjectMetadataType extends ExpandableStringEnum { + /** Static value Folder for SsisObjectMetadataType. */ + public static final SsisObjectMetadataType FOLDER = fromString("Folder"); + + /** Static value Project for SsisObjectMetadataType. */ + public static final SsisObjectMetadataType PROJECT = fromString("Project"); + + /** Static value Package for SsisObjectMetadataType. */ + public static final SsisObjectMetadataType PACKAGE = fromString("Package"); + + /** Static value Environment for SsisObjectMetadataType. */ + public static final SsisObjectMetadataType ENVIRONMENT = fromString("Environment"); + + /** + * Creates or finds a SsisObjectMetadataType from its string representation. + * @param name a name to look for + * @return the corresponding SsisObjectMetadataType + */ + @JsonCreator + public static SsisObjectMetadataType fromString(String name) { + return fromString(name, SsisObjectMetadataType.class); + } + + /** + * @return known SsisObjectMetadataType values + */ + public static Collection values() { + return values(SsisObjectMetadataType.class); + } +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/DataFactoryManagementClientImpl.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/DataFactoryManagementClientImpl.java index 75ace40ad7c9..3635e62d44f4 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/DataFactoryManagementClientImpl.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/DataFactoryManagementClientImpl.java @@ -171,6 +171,19 @@ public IntegrationRuntimesInner integrationRuntimes() { return this.integrationRuntimes; } + /** + * The IntegrationRuntimeObjectMetadatasInner object to access its operations. + */ + private IntegrationRuntimeObjectMetadatasInner integrationRuntimeObjectMetadatas; + + /** + * Gets the IntegrationRuntimeObjectMetadatasInner object to access its operations. + * @return the IntegrationRuntimeObjectMetadatasInner object. + */ + public IntegrationRuntimeObjectMetadatasInner integrationRuntimeObjectMetadatas() { + return this.integrationRuntimeObjectMetadatas; + } + /** * The IntegrationRuntimeNodesInner object to access its operations. */ @@ -326,6 +339,7 @@ protected void initialize() { this.operations = new OperationsInner(restClient().retrofit(), this); this.factories = new FactoriesInner(restClient().retrofit(), this); this.integrationRuntimes = new IntegrationRuntimesInner(restClient().retrofit(), this); + this.integrationRuntimeObjectMetadatas = new IntegrationRuntimeObjectMetadatasInner(restClient().retrofit(), this); this.integrationRuntimeNodes = new IntegrationRuntimeNodesInner(restClient().retrofit(), this); this.linkedServices = new LinkedServicesInner(restClient().retrofit(), this); this.datasets = new DatasetsInner(restClient().retrofit(), this); diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/DataFactoryManager.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/DataFactoryManager.java index 53196aab0da1..ce6363efe19f 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/DataFactoryManager.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/DataFactoryManager.java @@ -19,6 +19,7 @@ import com.microsoft.azure.management.datafactoryv2.v2018_06_01.Operations; import com.microsoft.azure.management.datafactoryv2.v2018_06_01.Factories; import com.microsoft.azure.management.datafactoryv2.v2018_06_01.IntegrationRuntimes; +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.IntegrationRuntimeObjectMetadatas; import com.microsoft.azure.management.datafactoryv2.v2018_06_01.IntegrationRuntimeNodes; import com.microsoft.azure.management.datafactoryv2.v2018_06_01.LinkedServices; import com.microsoft.azure.management.datafactoryv2.v2018_06_01.Datasets; @@ -38,6 +39,7 @@ public final class DataFactoryManager extends ManagerCore implements IntegrationRuntimeObjectMetadatas { + private final DataFactoryManager manager; + + IntegrationRuntimeObjectMetadatasImpl(DataFactoryManager manager) { + super(manager.inner().integrationRuntimeObjectMetadatas()); + this.manager = manager; + } + + public DataFactoryManager manager() { + return this.manager; + } + + @Override + public Completable refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + IntegrationRuntimeObjectMetadatasInner client = this.inner(); + return client.refreshAsync(resourceGroupName, factoryName, integrationRuntimeName).toCompletable(); + } + + @Override + public Observable getAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + IntegrationRuntimeObjectMetadatasInner client = this.inner(); + return client.getAsync(resourceGroupName, factoryName, integrationRuntimeName) + .map(new Func1() { + @Override + public SsisObjectMetadataListResponse call(SsisObjectMetadataListResponseInner inner) { + return new SsisObjectMetadataListResponseImpl(inner, manager()); + } + }); + } + +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java new file mode 100644 index 000000000000..97f97f854210 --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java @@ -0,0 +1,429 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation; + +import retrofit2.Retrofit; +import com.google.common.reflect.TypeToken; +import com.microsoft.azure.CloudException; +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.GetSsisObjectMetadataRequest; +import com.microsoft.rest.ServiceCallback; +import com.microsoft.rest.ServiceFuture; +import com.microsoft.rest.ServiceResponse; +import java.io.IOException; +import okhttp3.ResponseBody; +import retrofit2.http.Body; +import retrofit2.http.Header; +import retrofit2.http.Headers; +import retrofit2.http.Path; +import retrofit2.http.POST; +import retrofit2.http.Query; +import retrofit2.Response; +import rx.functions.Func1; +import rx.Observable; + +/** + * An instance of this class provides access to all the operations defined + * in IntegrationRuntimeObjectMetadatas. + */ +public class IntegrationRuntimeObjectMetadatasInner { + /** The Retrofit service to perform REST calls. */ + private IntegrationRuntimeObjectMetadatasService service; + /** The service client containing this operation class. */ + private DataFactoryManagementClientImpl client; + + /** + * Initializes an instance of IntegrationRuntimeObjectMetadatasInner. + * + * @param retrofit the Retrofit instance built from a Retrofit Builder. + * @param client the instance of the service client containing this operation class. + */ + public IntegrationRuntimeObjectMetadatasInner(Retrofit retrofit, DataFactoryManagementClientImpl client) { + this.service = retrofit.create(IntegrationRuntimeObjectMetadatasService.class); + this.client = client; + } + + /** + * The interface defining all the services for IntegrationRuntimeObjectMetadatas to be + * used by Retrofit to perform actually REST calls. + */ + interface IntegrationRuntimeObjectMetadatasService { + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactoryv2.v2018_06_01.IntegrationRuntimeObjectMetadatas refresh" }) + @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/integrationRuntimes/{integrationRuntimeName}/refreshObjectMetadata") + Observable> refresh(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Path("integrationRuntimeName") String integrationRuntimeName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactoryv2.v2018_06_01.IntegrationRuntimeObjectMetadatas beginRefresh" }) + @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/integrationRuntimes/{integrationRuntimeName}/refreshObjectMetadata") + Observable> beginRefresh(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Path("integrationRuntimeName") String integrationRuntimeName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactoryv2.v2018_06_01.IntegrationRuntimeObjectMetadatas get" }) + @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/integrationRuntimes/{integrationRuntimeName}/getObjectMetadata") + Observable> get(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Path("integrationRuntimeName") String integrationRuntimeName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Body GetSsisObjectMetadataRequest getMetadataRequest, @Header("User-Agent") String userAgent); + + } + + /** + * Refresh a ssis integration runtime object metadata. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws CloudException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + */ + public void refresh(String resourceGroupName, String factoryName, String integrationRuntimeName) { + refreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).toBlocking().last().body(); + } + + /** + * Refresh a ssis integration runtime object metadata. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(refreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName), serviceCallback); + } + + /** + * Refresh a ssis integration runtime object metadata. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + public Observable refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + return refreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).map(new Func1, Void>() { + @Override + public Void call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Refresh a ssis integration runtime object metadata. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + public Observable> refreshWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (factoryName == null) { + throw new IllegalArgumentException("Parameter factoryName is required and cannot be null."); + } + if (integrationRuntimeName == null) { + throw new IllegalArgumentException("Parameter integrationRuntimeName is required and cannot be null."); + } + if (this.client.apiVersion() == null) { + throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null."); + } + Observable> observable = service.refresh(this.client.subscriptionId(), resourceGroupName, factoryName, integrationRuntimeName, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()); + return client.getAzureClient().getPostOrDeleteResultAsync(observable, new TypeToken() { }.getType()); + } + + /** + * Refresh a ssis integration runtime object metadata. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws CloudException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + */ + public void beginRefresh(String resourceGroupName, String factoryName, String integrationRuntimeName) { + beginRefreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).toBlocking().single().body(); + } + + /** + * Refresh a ssis integration runtime object metadata. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture beginRefreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(beginRefreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName), serviceCallback); + } + + /** + * Refresh a ssis integration runtime object metadata. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceResponse} object if successful. + */ + public Observable beginRefreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + return beginRefreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).map(new Func1, Void>() { + @Override + public Void call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Refresh a ssis integration runtime object metadata. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceResponse} object if successful. + */ + public Observable> beginRefreshWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (factoryName == null) { + throw new IllegalArgumentException("Parameter factoryName is required and cannot be null."); + } + if (integrationRuntimeName == null) { + throw new IllegalArgumentException("Parameter integrationRuntimeName is required and cannot be null."); + } + if (this.client.apiVersion() == null) { + throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null."); + } + return service.beginRefresh(this.client.subscriptionId(), resourceGroupName, factoryName, integrationRuntimeName, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = beginRefreshDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse beginRefreshDelegate(Response response) throws CloudException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken() { }.getType()) + .register(202, new TypeToken() { }.getType()) + .registerError(CloudException.class) + .build(response); + } + + /** + * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws CloudException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the SsisObjectMetadataListResponseInner object if successful. + */ + public SsisObjectMetadataListResponseInner get(String resourceGroupName, String factoryName, String integrationRuntimeName) { + return getWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).toBlocking().single().body(); + } + + /** + * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture getAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(getWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName), serviceCallback); + } + + /** + * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the SsisObjectMetadataListResponseInner object + */ + public Observable getAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + return getWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).map(new Func1, SsisObjectMetadataListResponseInner>() { + @Override + public SsisObjectMetadataListResponseInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the SsisObjectMetadataListResponseInner object + */ + public Observable> getWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (factoryName == null) { + throw new IllegalArgumentException("Parameter factoryName is required and cannot be null."); + } + if (integrationRuntimeName == null) { + throw new IllegalArgumentException("Parameter integrationRuntimeName is required and cannot be null."); + } + if (this.client.apiVersion() == null) { + throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null."); + } + final String metadataPath = null; + GetSsisObjectMetadataRequest getMetadataRequest = new GetSsisObjectMetadataRequest(); + getMetadataRequest.withMetadataPath(null); + return service.get(this.client.subscriptionId(), resourceGroupName, factoryName, integrationRuntimeName, this.client.apiVersion(), this.client.acceptLanguage(), getMetadataRequest, this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = getDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + /** + * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @param metadataPath Metadata path + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws CloudException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the SsisObjectMetadataListResponseInner object if successful. + */ + public SsisObjectMetadataListResponseInner get(String resourceGroupName, String factoryName, String integrationRuntimeName, String metadataPath) { + return getWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName, metadataPath).toBlocking().single().body(); + } + + /** + * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @param metadataPath Metadata path + * @param serviceCallback the async ServiceCallback to handle successful and failed responses. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceFuture} object + */ + public ServiceFuture getAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, String metadataPath, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(getWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName, metadataPath), serviceCallback); + } + + /** + * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @param metadataPath Metadata path + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the SsisObjectMetadataListResponseInner object + */ + public Observable getAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, String metadataPath) { + return getWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName, metadataPath).map(new Func1, SsisObjectMetadataListResponseInner>() { + @Override + public SsisObjectMetadataListResponseInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param integrationRuntimeName The integration runtime name. + * @param metadataPath Metadata path + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the SsisObjectMetadataListResponseInner object + */ + public Observable> getWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, String metadataPath) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (resourceGroupName == null) { + throw new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."); + } + if (factoryName == null) { + throw new IllegalArgumentException("Parameter factoryName is required and cannot be null."); + } + if (integrationRuntimeName == null) { + throw new IllegalArgumentException("Parameter integrationRuntimeName is required and cannot be null."); + } + if (this.client.apiVersion() == null) { + throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null."); + } + GetSsisObjectMetadataRequest getMetadataRequest = null; + if (metadataPath != null) { + getMetadataRequest = new GetSsisObjectMetadataRequest(); + getMetadataRequest.withMetadataPath(metadataPath); + } + return service.get(this.client.subscriptionId(), resourceGroupName, factoryName, integrationRuntimeName, this.client.apiVersion(), this.client.acceptLanguage(), getMetadataRequest, this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = getDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse getDelegate(Response response) throws CloudException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken() { }.getType()) + .registerError(CloudException.class) + .build(response); + } + +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataListResponseImpl.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataListResponseImpl.java new file mode 100644 index 000000000000..159c4d7733ff --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataListResponseImpl.java @@ -0,0 +1,38 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation; + +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.SsisObjectMetadataListResponse; +import com.microsoft.azure.arm.model.implementation.WrapperImpl; +import java.util.List; +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.SsisObjectMetadata; + +class SsisObjectMetadataListResponseImpl extends WrapperImpl implements SsisObjectMetadataListResponse { + private final DataFactoryManager manager; + SsisObjectMetadataListResponseImpl(SsisObjectMetadataListResponseInner inner, DataFactoryManager manager) { + super(inner); + this.manager = manager; + } + + @Override + public DataFactoryManager manager() { + return this.manager; + } + + @Override + public String nextLink() { + return this.inner().nextLink(); + } + + @Override + public List value() { + return this.inner().value(); + } + +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataListResponseInner.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataListResponseInner.java new file mode 100644 index 000000000000..a264e4c329a2 --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataListResponseInner.java @@ -0,0 +1,71 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation; + +import java.util.List; +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.SsisObjectMetadata; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * A list of Ssis object metadata. + */ +public class SsisObjectMetadataListResponseInner { + /** + * List of Ssis object metadata. + */ + @JsonProperty(value = "value") + private List value; + + /** + * The link to the next page of results, if any remaining results exist. + */ + @JsonProperty(value = "nextLink") + private String nextLink; + + /** + * Get list of Ssis object metadata. + * + * @return the value value + */ + public List value() { + return this.value; + } + + /** + * Set list of Ssis object metadata. + * + * @param value the value value to set + * @return the SsisObjectMetadataListResponseInner object itself. + */ + public SsisObjectMetadataListResponseInner withValue(List value) { + this.value = value; + return this; + } + + /** + * Get the link to the next page of results, if any remaining results exist. + * + * @return the nextLink value + */ + public String nextLink() { + return this.nextLink; + } + + /** + * Set the link to the next page of results, if any remaining results exist. + * + * @param nextLink the nextLink value to set + * @return the SsisObjectMetadataListResponseInner object itself. + */ + public SsisObjectMetadataListResponseInner withNextLink(String nextLink) { + this.nextLink = nextLink; + return this; + } + +} From e1a5823095472e65114def6e8ae435490e777256 Mon Sep 17 00:00:00 2001 From: Azure SDK for Python bot Date: Fri, 7 Dec 2018 03:21:14 +0000 Subject: [PATCH 2/3] Generated from 38fb817c3d29a206d1371a3d4cea5002cc960535 Change ssis to upper case --- .../v2018_06_01/DeleteActivity.java | 89 ++++++++++++++++- .../GetSsisObjectMetadataRequest.java | 2 +- .../v2018_06_01/HDInsightHiveActivity.java | 53 ++++++++++ .../v2018_06_01/HDInsightLinkedService.java | 27 ++++++ .../IntegrationRuntimeObjectMetadatas.java | 4 +- .../v2018_06_01/LogStorageSettings.java | 97 +++++++++++++++++++ .../v2018_06_01/SsisObjectMetadata.java | 2 +- ...ntegrationRuntimeObjectMetadatasInner.java | 40 ++++---- .../SsisObjectMetadataListResponseInner.java | 8 +- 9 files changed, 290 insertions(+), 32 deletions(-) create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/LogStorageSettings.java diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/DeleteActivity.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/DeleteActivity.java index e9ff991aa027..27c9ba936a87 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/DeleteActivity.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/DeleteActivity.java @@ -21,12 +21,33 @@ @JsonFlatten public class DeleteActivity extends ExecutionActivity { /** - * If true, files under the folder path will be deleted recursively. - * Default is true. Type: boolean (or Expression with resultType boolean). + * If true, files or sub-folders under current folder path will be deleted + * recursively. Default is false. Type: boolean (or Expression with + * resultType boolean). */ @JsonProperty(value = "typeProperties.recursive") private Object recursive; + /** + * The max concurrent connections to connect data source at the same time. + */ + @JsonProperty(value = "typeProperties.maxConcurrentConnections") + private Integer maxConcurrentConnections; + + /** + * Whether to record detailed logs of delete-activity execution. Default + * value is false. Type: boolean (or Expression with resultType boolean). + */ + @JsonProperty(value = "typeProperties.enableLogging") + private Object enableLogging; + + /** + * Log storage settings customer need to provide when enableLogging is + * true. + */ + @JsonProperty(value = "typeProperties.logStorageSettings") + private LogStorageSettings logStorageSettings; + /** * Delete activity dataset reference. */ @@ -34,7 +55,7 @@ public class DeleteActivity extends ExecutionActivity { private DatasetReference dataset; /** - * Get if true, files under the folder path will be deleted recursively. Default is true. Type: boolean (or Expression with resultType boolean). + * Get if true, files or sub-folders under current folder path will be deleted recursively. Default is false. Type: boolean (or Expression with resultType boolean). * * @return the recursive value */ @@ -43,7 +64,7 @@ public Object recursive() { } /** - * Set if true, files under the folder path will be deleted recursively. Default is true. Type: boolean (or Expression with resultType boolean). + * Set if true, files or sub-folders under current folder path will be deleted recursively. Default is false. Type: boolean (or Expression with resultType boolean). * * @param recursive the recursive value to set * @return the DeleteActivity object itself. @@ -53,6 +74,66 @@ public DeleteActivity withRecursive(Object recursive) { return this; } + /** + * Get the max concurrent connections to connect data source at the same time. + * + * @return the maxConcurrentConnections value + */ + public Integer maxConcurrentConnections() { + return this.maxConcurrentConnections; + } + + /** + * Set the max concurrent connections to connect data source at the same time. + * + * @param maxConcurrentConnections the maxConcurrentConnections value to set + * @return the DeleteActivity object itself. + */ + public DeleteActivity withMaxConcurrentConnections(Integer maxConcurrentConnections) { + this.maxConcurrentConnections = maxConcurrentConnections; + return this; + } + + /** + * Get whether to record detailed logs of delete-activity execution. Default value is false. Type: boolean (or Expression with resultType boolean). + * + * @return the enableLogging value + */ + public Object enableLogging() { + return this.enableLogging; + } + + /** + * Set whether to record detailed logs of delete-activity execution. Default value is false. Type: boolean (or Expression with resultType boolean). + * + * @param enableLogging the enableLogging value to set + * @return the DeleteActivity object itself. + */ + public DeleteActivity withEnableLogging(Object enableLogging) { + this.enableLogging = enableLogging; + return this; + } + + /** + * Get log storage settings customer need to provide when enableLogging is true. + * + * @return the logStorageSettings value + */ + public LogStorageSettings logStorageSettings() { + return this.logStorageSettings; + } + + /** + * Set log storage settings customer need to provide when enableLogging is true. + * + * @param logStorageSettings the logStorageSettings value to set + * @return the DeleteActivity object itself. + */ + public DeleteActivity withLogStorageSettings(LogStorageSettings logStorageSettings) { + this.logStorageSettings = logStorageSettings; + return this; + } + /** * Get delete activity dataset reference. * diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/GetSsisObjectMetadataRequest.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/GetSsisObjectMetadataRequest.java index bb8fff41ab32..74508394ee66 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/GetSsisObjectMetadataRequest.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/GetSsisObjectMetadataRequest.java @@ -11,7 +11,7 @@ import com.fasterxml.jackson.annotation.JsonProperty; /** - * The request payload of get ssis object metadata. + * The request payload of get SSIS object metadata. */ public class GetSsisObjectMetadataRequest { /** diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/HDInsightHiveActivity.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/HDInsightHiveActivity.java index 09c5c5cd49af..accb3b9f6f8f 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/HDInsightHiveActivity.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/HDInsightHiveActivity.java @@ -58,6 +58,19 @@ public class HDInsightHiveActivity extends ExecutionActivity { @JsonProperty(value = "typeProperties.defines") private Map defines; + /** + * User specified arguments under hivevar namespace. + */ + @JsonProperty(value = "typeProperties.variables") + private List variables; + + /** + * Query timeout value (in minutes). Effective when the HDInsight culster + * is with ESP (Enterprise Security Package). + */ + @JsonProperty(value = "typeProperties.queryTimeout") + private Integer queryTimeout; + /** * Get storage linked service references. * @@ -178,4 +191,44 @@ public HDInsightHiveActivity withDefines(Map defines) { return this; } + /** + * Get user specified arguments under hivevar namespace. + * + * @return the variables value + */ + public List variables() { + return this.variables; + } + + /** + * Set user specified arguments under hivevar namespace. + * + * @param variables the variables value to set + * @return the HDInsightHiveActivity object itself. + */ + public HDInsightHiveActivity withVariables(List variables) { + this.variables = variables; + return this; + } + + /** + * Get query timeout value (in minutes). Effective when the HDInsight culster is with ESP (Enterprise Security Package). + * + * @return the queryTimeout value + */ + public Integer queryTimeout() { + return this.queryTimeout; + } + + /** + * Set query timeout value (in minutes). Effective when the HDInsight culster is with ESP (Enterprise Security Package). + * + * @param queryTimeout the queryTimeout value to set + * @return the HDInsightHiveActivity object itself. + */ + public HDInsightHiveActivity withQueryTimeout(Integer queryTimeout) { + this.queryTimeout = queryTimeout; + return this; + } + } diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/HDInsightLinkedService.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/HDInsightLinkedService.java index d7f80aa1b521..135da052ddfd 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/HDInsightLinkedService.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/HDInsightLinkedService.java @@ -62,6 +62,13 @@ public class HDInsightLinkedService extends LinkedServiceInner { @JsonProperty(value = "typeProperties.encryptedCredential") private Object encryptedCredential; + /** + * Specify if the HDInsight is created with ESP (Enterprise Security + * Package). Type: Boolean. + */ + @JsonProperty(value = "typeProperties.isEspEnabled") + private Object isEspEnabled; + /** * Get hDInsight cluster URI. Type: string (or Expression with resultType string). * @@ -182,4 +189,24 @@ public HDInsightLinkedService withEncryptedCredential(Object encryptedCredential return this; } + /** + * Get specify if the HDInsight is created with ESP (Enterprise Security Package). Type: Boolean. + * + * @return the isEspEnabled value + */ + public Object isEspEnabled() { + return this.isEspEnabled; + } + + /** + * Set specify if the HDInsight is created with ESP (Enterprise Security Package). Type: Boolean. + * + * @param isEspEnabled the isEspEnabled value to set + * @return the HDInsightLinkedService object itself. + */ + public HDInsightLinkedService withIsEspEnabled(Object isEspEnabled) { + this.isEspEnabled = isEspEnabled; + return this; + } + } diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java index d1beea36af87..2974f3bd7d2a 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java @@ -18,7 +18,7 @@ */ public interface IntegrationRuntimeObjectMetadatas extends HasInner { /** - * Refresh a ssis integration runtime object metadata. + * Refresh a SSIS integration runtime object metadata. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -29,7 +29,7 @@ public interface IntegrationRuntimeObjectMetadatas extends HasInner additionalProperties; + + /** + * Log storage linked service reference. + */ + @JsonProperty(value = "linkedServiceName", required = true) + private LinkedServiceReference linkedServiceName; + + /** + * The path to storage for storing detailed logs of activity execution. + * Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "path") + private Object path; + + /** + * Get unmatched properties from the message are deserialized this collection. + * + * @return the additionalProperties value + */ + public Map additionalProperties() { + return this.additionalProperties; + } + + /** + * Set unmatched properties from the message are deserialized this collection. + * + * @param additionalProperties the additionalProperties value to set + * @return the LogStorageSettings object itself. + */ + public LogStorageSettings withAdditionalProperties(Map additionalProperties) { + this.additionalProperties = additionalProperties; + return this; + } + + /** + * Get log storage linked service reference. + * + * @return the linkedServiceName value + */ + public LinkedServiceReference linkedServiceName() { + return this.linkedServiceName; + } + + /** + * Set log storage linked service reference. + * + * @param linkedServiceName the linkedServiceName value to set + * @return the LogStorageSettings object itself. + */ + public LogStorageSettings withLinkedServiceName(LinkedServiceReference linkedServiceName) { + this.linkedServiceName = linkedServiceName; + return this; + } + + /** + * Get the path to storage for storing detailed logs of activity execution. Type: string (or Expression with resultType string). + * + * @return the path value + */ + public Object path() { + return this.path; + } + + /** + * Set the path to storage for storing detailed logs of activity execution. Type: string (or Expression with resultType string). + * + * @param path the path value to set + * @return the LogStorageSettings object itself. + */ + public LogStorageSettings withPath(Object path) { + this.path = path; + return this; + } + +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadata.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadata.java index a1137e11dac3..885e8d26f986 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadata.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadata.java @@ -13,7 +13,7 @@ import com.fasterxml.jackson.annotation.JsonTypeName; /** - * Ssis object metadata. + * SSIS object metadata. */ @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") @JsonTypeName("SsisObjectMetadata") diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java index 97f97f854210..067a562ffa78 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java @@ -68,7 +68,7 @@ interface IntegrationRuntimeObjectMetadatasService { } /** - * Refresh a ssis integration runtime object metadata. + * Refresh a SSIS integration runtime object metadata. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -82,7 +82,7 @@ public void refresh(String resourceGroupName, String factoryName, String integra } /** - * Refresh a ssis integration runtime object metadata. + * Refresh a SSIS integration runtime object metadata. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -96,7 +96,7 @@ public ServiceFuture refreshAsync(String resourceGroupName, String factory } /** - * Refresh a ssis integration runtime object metadata. + * Refresh a SSIS integration runtime object metadata. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -114,7 +114,7 @@ public Void call(ServiceResponse response) { } /** - * Refresh a ssis integration runtime object metadata. + * Refresh a SSIS integration runtime object metadata. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -143,7 +143,7 @@ public Observable> refreshWithServiceResponseAsync(String } /** - * Refresh a ssis integration runtime object metadata. + * Refresh a SSIS integration runtime object metadata. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -157,7 +157,7 @@ public void beginRefresh(String resourceGroupName, String factoryName, String in } /** - * Refresh a ssis integration runtime object metadata. + * Refresh a SSIS integration runtime object metadata. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -171,7 +171,7 @@ public ServiceFuture beginRefreshAsync(String resourceGroupName, String fa } /** - * Refresh a ssis integration runtime object metadata. + * Refresh a SSIS integration runtime object metadata. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -189,7 +189,7 @@ public Void call(ServiceResponse response) { } /** - * Refresh a ssis integration runtime object metadata. + * Refresh a SSIS integration runtime object metadata. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -236,7 +236,7 @@ private ServiceResponse beginRefreshDelegate(Response respon } /** - * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * Get a SSIS integration runtime object metadata by specified path. The return is pageable metadata list. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -251,7 +251,7 @@ public SsisObjectMetadataListResponseInner get(String resourceGroupName, String } /** - * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * Get a SSIS integration runtime object metadata by specified path. The return is pageable metadata list. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -265,7 +265,7 @@ public ServiceFuture getAsync(String resour } /** - * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * Get a SSIS integration runtime object metadata by specified path. The return is pageable metadata list. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. @@ -283,7 +283,7 @@ public SsisObjectMetadataListResponseInner call(ServiceResponse> call(Res } /** - * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * Get a SSIS integration runtime object metadata by specified path. The return is pageable metadata list. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. * @param integrationRuntimeName The integration runtime name. - * @param metadataPath Metadata path + * @param metadataPath Metadata path. * @throws IllegalArgumentException thrown if parameters fail the validation * @throws CloudException thrown if the request is rejected by server * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent @@ -341,12 +341,12 @@ public SsisObjectMetadataListResponseInner get(String resourceGroupName, String } /** - * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * Get a SSIS integration runtime object metadata by specified path. The return is pageable metadata list. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. * @param integrationRuntimeName The integration runtime name. - * @param metadataPath Metadata path + * @param metadataPath Metadata path. * @param serviceCallback the async ServiceCallback to handle successful and failed responses. * @throws IllegalArgumentException thrown if parameters fail the validation * @return the {@link ServiceFuture} object @@ -356,12 +356,12 @@ public ServiceFuture getAsync(String resour } /** - * Get a ssis integration runtime object metadata by specified path. The return is pageable metadata list. + * Get a SSIS integration runtime object metadata by specified path. The return is pageable metadata list. * * @param resourceGroupName The resource group name. * @param factoryName The factory name. * @param integrationRuntimeName The integration runtime name. - * @param metadataPath Metadata path + * @param metadataPath Metadata path. * @throws IllegalArgumentException thrown if parameters fail the validation * @return the observable to the SsisObjectMetadataListResponseInner object */ @@ -375,12 +375,12 @@ public SsisObjectMetadataListResponseInner call(ServiceResponse value; @@ -29,7 +29,7 @@ public class SsisObjectMetadataListResponseInner { private String nextLink; /** - * Get list of Ssis object metadata. + * Get list of SSIS object metadata. * * @return the value value */ @@ -38,7 +38,7 @@ public List value() { } /** - * Set list of Ssis object metadata. + * Set list of SSIS object metadata. * * @param value the value value to set * @return the SsisObjectMetadataListResponseInner object itself. From 59f3ef7c70839c499943c36317421f76dd6fa6ef Mon Sep 17 00:00:00 2001 From: Azure SDK for Python bot Date: Sat, 8 Dec 2018 04:13:52 +0000 Subject: [PATCH 3/3] Generated from 43c2dab88ba9dd4abfe793fddfe0c1156518c4a9 Fix model validation issue --- .../IntegrationRuntimeObjectMetadatas.java | 3 +- .../SsisObjectMetadataStatusResponse.java | 40 ++++++ ...IntegrationRuntimeObjectMetadatasImpl.java | 12 +- ...ntegrationRuntimeObjectMetadatasInner.java | 48 +++---- .../SsisObjectMetadataStatusResponseImpl.java | 46 +++++++ ...SsisObjectMetadataStatusResponseInner.java | 121 ++++++++++++++++++ 6 files changed, 242 insertions(+), 28 deletions(-) create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataStatusResponse.java create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataStatusResponseImpl.java create mode 100644 datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataStatusResponseInner.java diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java index 2974f3bd7d2a..1252d6dd6d1b 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/IntegrationRuntimeObjectMetadatas.java @@ -8,7 +8,6 @@ package com.microsoft.azure.management.datafactoryv2.v2018_06_01; -import rx.Completable; import rx.Observable; import com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation.IntegrationRuntimeObjectMetadatasInner; import com.microsoft.azure.arm.model.HasInner; @@ -26,7 +25,7 @@ public interface IntegrationRuntimeObjectMetadatas extends HasInner refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName); /** * Get a SSIS integration runtime object metadata by specified path. The return is pageable metadata list. diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataStatusResponse.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataStatusResponse.java new file mode 100644 index 000000000000..59b7021c5fea --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/SsisObjectMetadataStatusResponse.java @@ -0,0 +1,40 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01; + +import com.microsoft.azure.arm.model.HasInner; +import com.microsoft.azure.arm.resources.models.HasManager; +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation.DataFactoryManager; +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation.SsisObjectMetadataStatusResponseInner; + +/** + * Type representing SsisObjectMetadataStatusResponse. + */ +public interface SsisObjectMetadataStatusResponse extends HasInner, HasManager { + /** + * @return the error value. + */ + String error(); + + /** + * @return the name value. + */ + String name(); + + /** + * @return the properties value. + */ + String properties(); + + /** + * @return the status value. + */ + String status(); + +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasImpl.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasImpl.java index 5d4176403e1c..be1f30de2f3f 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasImpl.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasImpl.java @@ -11,9 +11,9 @@ import com.microsoft.azure.arm.model.implementation.WrapperImpl; import com.microsoft.azure.management.datafactoryv2.v2018_06_01.IntegrationRuntimeObjectMetadatas; -import rx.Completable; import rx.functions.Func1; import rx.Observable; +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.SsisObjectMetadataStatusResponse; import com.microsoft.azure.management.datafactoryv2.v2018_06_01.SsisObjectMetadataListResponse; class IntegrationRuntimeObjectMetadatasImpl extends WrapperImpl implements IntegrationRuntimeObjectMetadatas { @@ -29,9 +29,15 @@ public DataFactoryManager manager() { } @Override - public Completable refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + public Observable refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { IntegrationRuntimeObjectMetadatasInner client = this.inner(); - return client.refreshAsync(resourceGroupName, factoryName, integrationRuntimeName).toCompletable(); + return client.refreshAsync(resourceGroupName, factoryName, integrationRuntimeName) + .map(new Func1() { + @Override + public SsisObjectMetadataStatusResponse call(SsisObjectMetadataStatusResponseInner inner) { + return new SsisObjectMetadataStatusResponseImpl(inner, manager()); + } + }); } @Override diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java index 067a562ffa78..ea04fda0478e 100644 --- a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/IntegrationRuntimeObjectMetadatasInner.java @@ -76,9 +76,10 @@ interface IntegrationRuntimeObjectMetadatasService { * @throws IllegalArgumentException thrown if parameters fail the validation * @throws CloudException thrown if the request is rejected by server * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the SsisObjectMetadataStatusResponseInner object if successful. */ - public void refresh(String resourceGroupName, String factoryName, String integrationRuntimeName) { - refreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).toBlocking().last().body(); + public SsisObjectMetadataStatusResponseInner refresh(String resourceGroupName, String factoryName, String integrationRuntimeName) { + return refreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).toBlocking().last().body(); } /** @@ -91,7 +92,7 @@ public void refresh(String resourceGroupName, String factoryName, String integra * @throws IllegalArgumentException thrown if parameters fail the validation * @return the {@link ServiceFuture} object */ - public ServiceFuture refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, final ServiceCallback serviceCallback) { + public ServiceFuture refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, final ServiceCallback serviceCallback) { return ServiceFuture.fromResponse(refreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName), serviceCallback); } @@ -104,10 +105,10 @@ public ServiceFuture refreshAsync(String resourceGroupName, String factory * @throws IllegalArgumentException thrown if parameters fail the validation * @return the observable for the request */ - public Observable refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { - return refreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).map(new Func1, Void>() { + public Observable refreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + return refreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).map(new Func1, SsisObjectMetadataStatusResponseInner>() { @Override - public Void call(ServiceResponse response) { + public SsisObjectMetadataStatusResponseInner call(ServiceResponse response) { return response.body(); } }); @@ -122,7 +123,7 @@ public Void call(ServiceResponse response) { * @throws IllegalArgumentException thrown if parameters fail the validation * @return the observable for the request */ - public Observable> refreshWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + public Observable> refreshWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { if (this.client.subscriptionId() == null) { throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); } @@ -139,7 +140,7 @@ public Observable> refreshWithServiceResponseAsync(String throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null."); } Observable> observable = service.refresh(this.client.subscriptionId(), resourceGroupName, factoryName, integrationRuntimeName, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()); - return client.getAzureClient().getPostOrDeleteResultAsync(observable, new TypeToken() { }.getType()); + return client.getAzureClient().getPostOrDeleteResultAsync(observable, new TypeToken() { }.getType()); } /** @@ -151,9 +152,10 @@ public Observable> refreshWithServiceResponseAsync(String * @throws IllegalArgumentException thrown if parameters fail the validation * @throws CloudException thrown if the request is rejected by server * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the SsisObjectMetadataStatusResponseInner object if successful. */ - public void beginRefresh(String resourceGroupName, String factoryName, String integrationRuntimeName) { - beginRefreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).toBlocking().single().body(); + public SsisObjectMetadataStatusResponseInner beginRefresh(String resourceGroupName, String factoryName, String integrationRuntimeName) { + return beginRefreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).toBlocking().single().body(); } /** @@ -166,7 +168,7 @@ public void beginRefresh(String resourceGroupName, String factoryName, String in * @throws IllegalArgumentException thrown if parameters fail the validation * @return the {@link ServiceFuture} object */ - public ServiceFuture beginRefreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, final ServiceCallback serviceCallback) { + public ServiceFuture beginRefreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, final ServiceCallback serviceCallback) { return ServiceFuture.fromResponse(beginRefreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName), serviceCallback); } @@ -177,12 +179,12 @@ public ServiceFuture beginRefreshAsync(String resourceGroupName, String fa * @param factoryName The factory name. * @param integrationRuntimeName The integration runtime name. * @throws IllegalArgumentException thrown if parameters fail the validation - * @return the {@link ServiceResponse} object if successful. + * @return the observable to the SsisObjectMetadataStatusResponseInner object */ - public Observable beginRefreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { - return beginRefreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).map(new Func1, Void>() { + public Observable beginRefreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + return beginRefreshWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName).map(new Func1, SsisObjectMetadataStatusResponseInner>() { @Override - public Void call(ServiceResponse response) { + public SsisObjectMetadataStatusResponseInner call(ServiceResponse response) { return response.body(); } }); @@ -195,9 +197,9 @@ public Void call(ServiceResponse response) { * @param factoryName The factory name. * @param integrationRuntimeName The integration runtime name. * @throws IllegalArgumentException thrown if parameters fail the validation - * @return the {@link ServiceResponse} object if successful. + * @return the observable to the SsisObjectMetadataStatusResponseInner object */ - public Observable> beginRefreshWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { + public Observable> beginRefreshWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { if (this.client.subscriptionId() == null) { throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); } @@ -214,11 +216,11 @@ public Observable> beginRefreshWithServiceResponseAsync(St throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null."); } return service.beginRefresh(this.client.subscriptionId(), resourceGroupName, factoryName, integrationRuntimeName, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()) - .flatMap(new Func1, Observable>>() { + .flatMap(new Func1, Observable>>() { @Override - public Observable> call(Response response) { + public Observable> call(Response response) { try { - ServiceResponse clientResponse = beginRefreshDelegate(response); + ServiceResponse clientResponse = beginRefreshDelegate(response); return Observable.just(clientResponse); } catch (Throwable t) { return Observable.error(t); @@ -227,9 +229,9 @@ public Observable> call(Response response) { }); } - private ServiceResponse beginRefreshDelegate(Response response) throws CloudException, IOException, IllegalArgumentException { - return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) - .register(200, new TypeToken() { }.getType()) + private ServiceResponse beginRefreshDelegate(Response response) throws CloudException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken() { }.getType()) .register(202, new TypeToken() { }.getType()) .registerError(CloudException.class) .build(response); diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataStatusResponseImpl.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataStatusResponseImpl.java new file mode 100644 index 000000000000..a930105b60c2 --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataStatusResponseImpl.java @@ -0,0 +1,46 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation; + +import com.microsoft.azure.management.datafactoryv2.v2018_06_01.SsisObjectMetadataStatusResponse; +import com.microsoft.azure.arm.model.implementation.WrapperImpl; + +class SsisObjectMetadataStatusResponseImpl extends WrapperImpl implements SsisObjectMetadataStatusResponse { + private final DataFactoryManager manager; + SsisObjectMetadataStatusResponseImpl(SsisObjectMetadataStatusResponseInner inner, DataFactoryManager manager) { + super(inner); + this.manager = manager; + } + + @Override + public DataFactoryManager manager() { + return this.manager; + } + + @Override + public String error() { + return this.inner().error(); + } + + @Override + public String name() { + return this.inner().name(); + } + + @Override + public String properties() { + return this.inner().properties(); + } + + @Override + public String status() { + return this.inner().status(); + } + +} diff --git a/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataStatusResponseInner.java b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataStatusResponseInner.java new file mode 100644 index 000000000000..046cad113162 --- /dev/null +++ b/datafactoryv2/resource-manager/v2018_06_01/src/main/java/com/microsoft/azure/management/datafactoryv2/v2018_06_01/implementation/SsisObjectMetadataStatusResponseInner.java @@ -0,0 +1,121 @@ +/** + * 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. + */ + +package com.microsoft.azure.management.datafactoryv2.v2018_06_01.implementation; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * The status of the operation. + */ +public class SsisObjectMetadataStatusResponseInner { + /** + * The status of the operation. + */ + @JsonProperty(value = "status") + private String status; + + /** + * The operation name. + */ + @JsonProperty(value = "name") + private String name; + + /** + * The operation properties. + */ + @JsonProperty(value = "properties") + private String properties; + + /** + * The operation error message. + */ + @JsonProperty(value = "error") + private String error; + + /** + * Get the status of the operation. + * + * @return the status value + */ + public String status() { + return this.status; + } + + /** + * Set the status of the operation. + * + * @param status the status value to set + * @return the SsisObjectMetadataStatusResponseInner object itself. + */ + public SsisObjectMetadataStatusResponseInner withStatus(String status) { + this.status = status; + return this; + } + + /** + * Get the operation name. + * + * @return the name value + */ + public String name() { + return this.name; + } + + /** + * Set the operation name. + * + * @param name the name value to set + * @return the SsisObjectMetadataStatusResponseInner object itself. + */ + public SsisObjectMetadataStatusResponseInner withName(String name) { + this.name = name; + return this; + } + + /** + * Get the operation properties. + * + * @return the properties value + */ + public String properties() { + return this.properties; + } + + /** + * Set the operation properties. + * + * @param properties the properties value to set + * @return the SsisObjectMetadataStatusResponseInner object itself. + */ + public SsisObjectMetadataStatusResponseInner withProperties(String properties) { + this.properties = properties; + return this; + } + + /** + * Get the operation error message. + * + * @return the error value + */ + public String error() { + return this.error; + } + + /** + * Set the operation error message. + * + * @param error the error value to set + * @return the SsisObjectMetadataStatusResponseInner object itself. + */ + public SsisObjectMetadataStatusResponseInner withError(String error) { + this.error = error; + return this; + } + +}