diff --git a/sdk/datafactory/mgmt-v2018_06_01/pom.xml b/sdk/datafactory/mgmt-v2018_06_01/pom.xml index fd7cea89e0a4b..6a01bee79fc62 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/pom.xml +++ b/sdk/datafactory/mgmt-v2018_06_01/pom.xml @@ -11,11 +11,11 @@ com.microsoft.azure azure-arm-parent - 1.3.2 - ../../parents/azure-arm-parent/pom.xml + 1.1.0 + ../../../pom.management.xml azure-mgmt-datafactory - 1.0.0-beta-3 + 1.0.0-beta jar Microsoft Azure SDK for DataFactory Management This package contains Microsoft DataFactory Management SDK. diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobFSLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobFSLinkedService.java index 0897fcc06624c..d2de106619733 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobFSLinkedService.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobFSLinkedService.java @@ -57,6 +57,15 @@ public class AzureBlobFSLinkedService extends LinkedServiceInner { @JsonProperty(value = "typeProperties.tenant") private Object tenant; + /** + * Indicates the azure cloud type of the service principle auth. Allowed + * values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. + * Default value is the data factory regions’ cloud type. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.azureCloudType") + private Object azureCloudType; + /** * The encrypted credential used for authentication. Credentials are * encrypted using the integration runtime credential manager. Type: string @@ -165,6 +174,26 @@ public AzureBlobFSLinkedService withTenant(Object tenant) { return this; } + /** + * Get indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @return the azureCloudType value + */ + public Object azureCloudType() { + return this.azureCloudType; + } + + /** + * Set indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @param azureCloudType the azureCloudType value to set + * @return the AzureBlobFSLinkedService object itself. + */ + public AzureBlobFSLinkedService withAzureCloudType(Object azureCloudType) { + this.azureCloudType = azureCloudType; + return this; + } + /** * Get the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string). * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobStorageLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobStorageLinkedService.java index 9f31fd001094a..546a4254dc4fe 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobStorageLinkedService.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureBlobStorageLinkedService.java @@ -77,6 +77,15 @@ public class AzureBlobStorageLinkedService extends LinkedServiceInner { @JsonProperty(value = "typeProperties.tenant") private Object tenant; + /** + * Indicates the azure cloud type of the service principle auth. Allowed + * values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. + * Default value is the data factory regions’ cloud type. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.azureCloudType") + private Object azureCloudType; + /** * The encrypted credential used for authentication. Credentials are * encrypted using the integration runtime credential manager. Type: string @@ -245,6 +254,26 @@ public AzureBlobStorageLinkedService withTenant(Object tenant) { return this; } + /** + * Get indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @return the azureCloudType value + */ + public Object azureCloudType() { + return this.azureCloudType; + } + + /** + * Set indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @param azureCloudType the azureCloudType value to set + * @return the AzureBlobStorageLinkedService object itself. + */ + public AzureBlobStorageLinkedService withAzureCloudType(Object azureCloudType) { + this.azureCloudType = azureCloudType; + return this; + } + /** * Get the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string). * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreLinkedService.java index b65c4f3463c2e..41a77ca1a57b4 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreLinkedService.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureDataLakeStoreLinkedService.java @@ -49,6 +49,15 @@ public class AzureDataLakeStoreLinkedService extends LinkedServiceInner { @JsonProperty(value = "typeProperties.tenant") private Object tenant; + /** + * Indicates the azure cloud type of the service principle auth. Allowed + * values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. + * Default value is the data factory regions’ cloud type. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.azureCloudType") + private Object azureCloudType; + /** * Data Lake Store account name. Type: string (or Expression with * resultType string). @@ -158,6 +167,26 @@ public AzureDataLakeStoreLinkedService withTenant(Object tenant) { return this; } + /** + * Get indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @return the azureCloudType value + */ + public Object azureCloudType() { + return this.azureCloudType; + } + + /** + * Set indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @param azureCloudType the azureCloudType value to set + * @return the AzureDataLakeStoreLinkedService object itself. + */ + public AzureDataLakeStoreLinkedService withAzureCloudType(Object azureCloudType) { + this.azureCloudType = azureCloudType; + return this; + } + /** * Get data Lake Store account name. Type: string (or Expression with resultType string). * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageLinkedService.java index 71c11abe047fd..f7e6a2d6649e9 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageLinkedService.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureFileStorageLinkedService.java @@ -76,6 +76,13 @@ public class AzureFileStorageLinkedService extends LinkedServiceInner { @JsonProperty(value = "typeProperties.fileShare") private Object fileShare; + /** + * The azure file share snapshot version. Type: string (or Expression with + * resultType string). + */ + @JsonProperty(value = "typeProperties.snapshot") + private Object snapshot; + /** * The encrypted credential used for authentication. Credentials are * encrypted using the integration runtime credential manager. Type: string @@ -244,6 +251,26 @@ public AzureFileStorageLinkedService withFileShare(Object fileShare) { return this; } + /** + * Get the azure file share snapshot version. Type: string (or Expression with resultType string). + * + * @return the snapshot value + */ + public Object snapshot() { + return this.snapshot; + } + + /** + * Set the azure file share snapshot version. Type: string (or Expression with resultType string). + * + * @param snapshot the snapshot value to set + * @return the AzureFileStorageLinkedService object itself. + */ + public AzureFileStorageLinkedService withSnapshot(Object snapshot) { + this.snapshot = snapshot; + return this; + } + /** * Get the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string). * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlDWLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlDWLinkedService.java index 0e16aaa0fa02c..52838a9e2e9e4 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlDWLinkedService.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlDWLinkedService.java @@ -56,6 +56,15 @@ public class AzureSqlDWLinkedService extends LinkedServiceInner { @JsonProperty(value = "typeProperties.tenant") private Object tenant; + /** + * Indicates the azure cloud type of the service principle auth. Allowed + * values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. + * Default value is the data factory regions’ cloud type. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.azureCloudType") + private Object azureCloudType; + /** * The encrypted credential used for authentication. Credentials are * encrypted using the integration runtime credential manager. Type: string @@ -164,6 +173,26 @@ public AzureSqlDWLinkedService withTenant(Object tenant) { return this; } + /** + * Get indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @return the azureCloudType value + */ + public Object azureCloudType() { + return this.azureCloudType; + } + + /** + * Set indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @param azureCloudType the azureCloudType value to set + * @return the AzureSqlDWLinkedService object itself. + */ + public AzureSqlDWLinkedService withAzureCloudType(Object azureCloudType) { + this.azureCloudType = azureCloudType; + return this; + } + /** * Get the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string). * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlDatabaseLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlDatabaseLinkedService.java index 3419c3e48400e..b358a1918e556 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlDatabaseLinkedService.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlDatabaseLinkedService.java @@ -55,6 +55,15 @@ public class AzureSqlDatabaseLinkedService extends LinkedServiceInner { @JsonProperty(value = "typeProperties.tenant") private Object tenant; + /** + * Indicates the azure cloud type of the service principle auth. Allowed + * values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. + * Default value is the data factory regions’ cloud type. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.azureCloudType") + private Object azureCloudType; + /** * The encrypted credential used for authentication. Credentials are * encrypted using the integration runtime credential manager. Type: string @@ -163,6 +172,26 @@ public AzureSqlDatabaseLinkedService withTenant(Object tenant) { return this; } + /** + * Get indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @return the azureCloudType value + */ + public Object azureCloudType() { + return this.azureCloudType; + } + + /** + * Set indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @param azureCloudType the azureCloudType value to set + * @return the AzureSqlDatabaseLinkedService object itself. + */ + public AzureSqlDatabaseLinkedService withAzureCloudType(Object azureCloudType) { + this.azureCloudType = azureCloudType; + return this; + } + /** * Get the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string). * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlMILinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlMILinkedService.java index 417ad6f30fad2..80d5cbe68b541 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlMILinkedService.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/AzureSqlMILinkedService.java @@ -55,6 +55,15 @@ public class AzureSqlMILinkedService extends LinkedServiceInner { @JsonProperty(value = "typeProperties.tenant") private Object tenant; + /** + * Indicates the azure cloud type of the service principle auth. Allowed + * values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. + * Default value is the data factory regions’ cloud type. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.azureCloudType") + private Object azureCloudType; + /** * The encrypted credential used for authentication. Credentials are * encrypted using the integration runtime credential manager. Type: string @@ -163,6 +172,26 @@ public AzureSqlMILinkedService withTenant(Object tenant) { return this; } + /** + * Get indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @return the azureCloudType value + */ + public Object azureCloudType() { + return this.azureCloudType; + } + + /** + * Set indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @param azureCloudType the azureCloudType value to set + * @return the AzureSqlMILinkedService object itself. + */ + public AzureSqlMILinkedService withAzureCloudType(Object azureCloudType) { + this.azureCloudType = azureCloudType; + return this; + } + /** * Get the encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string). * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DataFlowSink.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DataFlowSink.java index 27d82aa33f7ad..9ee02863f89a9 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DataFlowSink.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DataFlowSink.java @@ -32,6 +32,12 @@ public class DataFlowSink extends Transformation { @JsonProperty(value = "schemaLinkedService") private LinkedServiceReference schemaLinkedService; + /** + * Staging info for execute data flow activity. + */ + @JsonProperty(value = "staging") + private DataFlowStagingInfo staging; + /** * Get dataset reference. * @@ -92,4 +98,24 @@ public DataFlowSink withSchemaLinkedService(LinkedServiceReference schemaLinkedS return this; } + /** + * Get staging info for execute data flow activity. + * + * @return the staging value + */ + public DataFlowStagingInfo staging() { + return this.staging; + } + + /** + * Set staging info for execute data flow activity. + * + * @param staging the staging value to set + * @return the DataFlowSink object itself. + */ + public DataFlowSink withStaging(DataFlowStagingInfo staging) { + this.staging = staging; + return this; + } + } diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DataFlowSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DataFlowSource.java index 72f5cd40bbd10..baf8653d7ded1 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DataFlowSource.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/DataFlowSource.java @@ -32,6 +32,12 @@ public class DataFlowSource extends Transformation { @JsonProperty(value = "schemaLinkedService") private LinkedServiceReference schemaLinkedService; + /** + * Staging info for execute data flow activity. + */ + @JsonProperty(value = "staging") + private DataFlowStagingInfo staging; + /** * Get dataset reference. * @@ -92,4 +98,24 @@ public DataFlowSource withSchemaLinkedService(LinkedServiceReference schemaLinke return this; } + /** + * Get staging info for execute data flow activity. + * + * @return the staging value + */ + public DataFlowStagingInfo staging() { + return this.staging; + } + + /** + * Set staging info for execute data flow activity. + * + * @param staging the staging value to set + * @return the DataFlowSource object itself. + */ + public DataFlowSource withStaging(DataFlowStagingInfo staging) { + this.staging = staging; + return this; + } + } diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExposureControlBatchRequest.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExposureControlBatchRequest.java new file mode 100644 index 0000000000000..02922a105dd79 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExposureControlBatchRequest.java @@ -0,0 +1,44 @@ +/** + * 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.datafactory.v2018_06_01; + +import java.util.List; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * A list of exposure control features. + */ +public class ExposureControlBatchRequest { + /** + * List of exposure control features. + */ + @JsonProperty(value = "exposureControlRequests", required = true) + private List exposureControlRequests; + + /** + * Get list of exposure control features. + * + * @return the exposureControlRequests value + */ + public List exposureControlRequests() { + return this.exposureControlRequests; + } + + /** + * Set list of exposure control features. + * + * @param exposureControlRequests the exposureControlRequests value to set + * @return the ExposureControlBatchRequest object itself. + */ + public ExposureControlBatchRequest withExposureControlRequests(List exposureControlRequests) { + this.exposureControlRequests = exposureControlRequests; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExposureControlBatchResponse.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExposureControlBatchResponse.java new file mode 100644 index 0000000000000..05922894f210b --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExposureControlBatchResponse.java @@ -0,0 +1,27 @@ +/** + * 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.datafactory.v2018_06_01; + +import com.microsoft.azure.arm.model.HasInner; +import com.microsoft.azure.arm.resources.models.HasManager; +import com.microsoft.azure.management.datafactory.v2018_06_01.implementation.DataFactoryManager; +import com.microsoft.azure.management.datafactory.v2018_06_01.implementation.ExposureControlBatchResponseInner; +import com.microsoft.azure.management.datafactory.v2018_06_01.implementation.ExposureControlResponseInner; +import java.util.List; + +/** + * Type representing ExposureControlBatchResponse. + */ +public interface ExposureControlBatchResponse extends HasInner, HasManager { + /** + * @return the exposureControlResponses value. + */ + List exposureControlResponses(); + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExposureControls.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExposureControls.java index 49a99cf4c44ab..df88d6ad0266a 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExposureControls.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ExposureControls.java @@ -9,6 +9,7 @@ package com.microsoft.azure.management.datafactory.v2018_06_01; import rx.Observable; +import java.util.List; /** * Type representing ExposureControls. @@ -35,4 +36,15 @@ public interface ExposureControls { */ Observable getFeatureValueByFactoryAsync(String resourceGroupName, String factoryName, ExposureControlRequest exposureControlRequest); + /** + * Get list of exposure control features for specific factory. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param exposureControlRequests List of exposure control features. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + Observable queryFeatureValuesByFactoryAsync(String resourceGroupName, String factoryName, List exposureControlRequests); + } diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ODataLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ODataLinkedService.java index cfcb325f8834f..088291ba8a3f7 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ODataLinkedService.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/ODataLinkedService.java @@ -64,6 +64,15 @@ public class ODataLinkedService extends LinkedServiceInner { @JsonProperty(value = "typeProperties.servicePrincipalId") private Object servicePrincipalId; + /** + * Indicates the azure cloud type of the service principle auth. Allowed + * values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. + * Default value is the data factory regions’ cloud type. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.azureCloudType") + private Object azureCloudType; + /** * Specify the resource you are requesting authorization to use Directory. * Type: string (or Expression with resultType string). @@ -229,6 +238,26 @@ public ODataLinkedService withServicePrincipalId(Object servicePrincipalId) { return this; } + /** + * Get indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @return the azureCloudType value + */ + public Object azureCloudType() { + return this.azureCloudType; + } + + /** + * Set indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @param azureCloudType the azureCloudType value to set + * @return the ODataLinkedService object itself. + */ + public ODataLinkedService withAzureCloudType(Object azureCloudType) { + this.azureCloudType = azureCloudType; + return this; + } + /** * Get specify the resource you are requesting authorization to use Directory. Type: string (or Expression with resultType string). * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RestServiceLinkedService.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RestServiceLinkedService.java index 957d0c8b7e01f..1bc381f8f0fdf 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RestServiceLinkedService.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/RestServiceLinkedService.java @@ -76,6 +76,15 @@ public class RestServiceLinkedService extends LinkedServiceInner { @JsonProperty(value = "typeProperties.tenant") private Object tenant; + /** + * Indicates the azure cloud type of the service principle auth. Allowed + * values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. + * Default value is the data factory regions’ cloud type. Type: string (or + * Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.azureCloudType") + private Object azureCloudType; + /** * The resource you are requesting authorization to use. */ @@ -250,6 +259,26 @@ public RestServiceLinkedService withTenant(Object tenant) { return this; } + /** + * Get indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @return the azureCloudType value + */ + public Object azureCloudType() { + return this.azureCloudType; + } + + /** + * Set indicates the azure cloud type of the service principle auth. Allowed values are AzurePublic, AzureChina, AzureUsGovernment, AzureGermany. Default value is the data factory regions’ cloud type. Type: string (or Expression with resultType string). + * + * @param azureCloudType the azureCloudType value to set + * @return the RestServiceLinkedService object itself. + */ + public RestServiceLinkedService withAzureCloudType(Object azureCloudType) { + this.azureCloudType = azureCloudType; + return this; + } + /** * Get the resource you are requesting authorization to use. * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapOpenHubSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapOpenHubSource.java index de0f7e3d371d6..b5a079cdd0191 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapOpenHubSource.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapOpenHubSource.java @@ -35,6 +35,21 @@ public class SapOpenHubSource extends TabularSource { @JsonProperty(value = "baseRequestId") private Object baseRequestId; + /** + * Specifies the custom RFC function module that will be used to read data + * from SAP Table. Type: string (or Expression with resultType string). + */ + @JsonProperty(value = "customRfcReadTableFunctionModule") + private Object customRfcReadTableFunctionModule; + + /** + * The single character that will be used as delimiter passed to SAP RFC as + * well as splitting the output data retrieved. Type: string (or Expression + * with resultType string). + */ + @JsonProperty(value = "sapDataColumnDelimiter") + private Object sapDataColumnDelimiter; + /** * Get whether to exclude the records of the last request. The default value is true. Type: boolean (or Expression with resultType boolean). * @@ -75,4 +90,44 @@ public SapOpenHubSource withBaseRequestId(Object baseRequestId) { return this; } + /** + * Get specifies the custom RFC function module that will be used to read data from SAP Table. Type: string (or Expression with resultType string). + * + * @return the customRfcReadTableFunctionModule value + */ + public Object customRfcReadTableFunctionModule() { + return this.customRfcReadTableFunctionModule; + } + + /** + * Set specifies the custom RFC function module that will be used to read data from SAP Table. Type: string (or Expression with resultType string). + * + * @param customRfcReadTableFunctionModule the customRfcReadTableFunctionModule value to set + * @return the SapOpenHubSource object itself. + */ + public SapOpenHubSource withCustomRfcReadTableFunctionModule(Object customRfcReadTableFunctionModule) { + this.customRfcReadTableFunctionModule = customRfcReadTableFunctionModule; + return this; + } + + /** + * Get the single character that will be used as delimiter passed to SAP RFC as well as splitting the output data retrieved. Type: string (or Expression with resultType string). + * + * @return the sapDataColumnDelimiter value + */ + public Object sapDataColumnDelimiter() { + return this.sapDataColumnDelimiter; + } + + /** + * Set the single character that will be used as delimiter passed to SAP RFC as well as splitting the output data retrieved. Type: string (or Expression with resultType string). + * + * @param sapDataColumnDelimiter the sapDataColumnDelimiter value to set + * @return the SapOpenHubSource object itself. + */ + public SapOpenHubSource withSapDataColumnDelimiter(Object sapDataColumnDelimiter) { + this.sapDataColumnDelimiter = sapDataColumnDelimiter; + return this; + } + } diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapTableSource.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapTableSource.java index a617a80852bba..ecf0f409877c9 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapTableSource.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/SapTableSource.java @@ -61,6 +61,14 @@ public class SapTableSource extends TabularSource { @JsonProperty(value = "customRfcReadTableFunctionModule") private Object customRfcReadTableFunctionModule; + /** + * The single character that will be used as delimiter passed to SAP RFC as + * well as splitting the output data retrieved. Type: string (or Expression + * with resultType string). + */ + @JsonProperty(value = "sapDataColumnDelimiter") + private Object sapDataColumnDelimiter; + /** * The partition mechanism that will be used for SAP table read in * parallel. Possible values include: 'None', 'PartitionOnInt', @@ -196,6 +204,26 @@ public SapTableSource withCustomRfcReadTableFunctionModule(Object customRfcReadT return this; } + /** + * Get the single character that will be used as delimiter passed to SAP RFC as well as splitting the output data retrieved. Type: string (or Expression with resultType string). + * + * @return the sapDataColumnDelimiter value + */ + public Object sapDataColumnDelimiter() { + return this.sapDataColumnDelimiter; + } + + /** + * Set the single character that will be used as delimiter passed to SAP RFC as well as splitting the output data retrieved. Type: string (or Expression with resultType string). + * + * @param sapDataColumnDelimiter the sapDataColumnDelimiter value to set + * @return the SapTableSource object itself. + */ + public SapTableSource withSapDataColumnDelimiter(Object sapDataColumnDelimiter) { + this.sapDataColumnDelimiter = sapDataColumnDelimiter; + return this; + } + /** * Get the partition mechanism that will be used for SAP table read in parallel. Possible values include: 'None', 'PartitionOnInt', 'PartitionOnCalendarYear', 'PartitionOnCalendarMonth', 'PartitionOnCalendarDate', 'PartitionOnTime'. * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/TriggerRuns.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/TriggerRuns.java index bdce89dc5fefb..90e02ff9a0dc3 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/TriggerRuns.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/TriggerRuns.java @@ -27,6 +27,18 @@ public interface TriggerRuns { */ Completable rerunAsync(String resourceGroupName, String factoryName, String triggerName, String runId); + /** + * Cancel a single trigger instance by runId. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param triggerName The trigger name. + * @param runId The pipeline run identifier. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable for the request + */ + Completable cancelAsync(String resourceGroupName, String factoryName, String triggerName, String runId); + /** * Query trigger runs. * diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/WebHookActivity.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/WebHookActivity.java index d5fc0dc0ce56a..32fc477301e74 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/WebHookActivity.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/WebHookActivity.java @@ -65,9 +65,9 @@ public class WebHookActivity extends ControlActivity { private WebActivityAuthentication authentication; /** - * When set to true, statusCode, output and error in callback request body - * will be consumed by activity. The activity can be marked as failed by - * setting statusCode >= 400 in callback request. Default is false. + * When set to true, statusCode, output and error in callback request body + * will be consumed by activity. The activity can be marked as failed by + * setting statusCode >= 400 in callback request. Default is false. * Type: boolean (or Expression with resultType boolean). */ @JsonProperty(value = "typeProperties.reportStatusOnCallBack") @@ -202,7 +202,7 @@ public WebHookActivity withAuthentication(WebActivityAuthentication authenticati } /** - * Get when set to true, statusCode, output and error in callback request body will be consumed by activity. The activity can be marked as failed by setting statusCode >= 400 in callback request. Default is false. Type: boolean (or Expression with resultType boolean). + * Get when set to true, statusCode, output and error in callback request body will be consumed by activity. The activity can be marked as failed by setting statusCode >= 400 in callback request. Default is false. Type: boolean (or Expression with resultType boolean). * * @return the reportStatusOnCallBack value */ @@ -211,7 +211,7 @@ public Object reportStatusOnCallBack() { } /** - * Set when set to true, statusCode, output and error in callback request body will be consumed by activity. The activity can be marked as failed by setting statusCode >= 400 in callback request. Default is false. Type: boolean (or Expression with resultType boolean). + * Set when set to true, statusCode, output and error in callback request body will be consumed by activity. The activity can be marked as failed by setting statusCode >= 400 in callback request. Default is false. Type: boolean (or Expression with resultType boolean). * * @param reportStatusOnCallBack the reportStatusOnCallBack value to set * @return the WebHookActivity object itself. diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DataFlowInner.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DataFlowInner.java index ae6b5b3cdcbdd..640ce52d1e970 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DataFlowInner.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DataFlowInner.java @@ -14,7 +14,6 @@ import com.fasterxml.jackson.annotation.JsonTypeInfo; import com.fasterxml.jackson.annotation.JsonTypeName; import com.fasterxml.jackson.annotation.JsonSubTypes; -import com.microsoft.azure.management.datafactory.v2018_06_01.MappingDataFlow; /** * Azure Data Factory nested object which contains a flow with data movements diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DatasetInner.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DatasetInner.java index 36a1d9211b326..e6a553623dcae 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DatasetInner.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DatasetInner.java @@ -9,67 +9,7 @@ package com.microsoft.azure.management.datafactory.v2018_06_01.implementation; import java.util.Map; - -import com.microsoft.azure.management.datafactory.v2018_06_01.AmazonMWSObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AmazonRedshiftTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AmazonS3Dataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AvroDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureBlobDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureBlobFSDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureDataExplorerTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureDataLakeStoreDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureMariaDBTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureMySqlTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzurePostgreSqlTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureSearchIndexDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureSqlDWTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureSqlMITableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureSqlTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.BinaryDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.CassandraTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.CommonDataServiceForAppsEntityDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.ConcurObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.CosmosDbMongoDbApiCollectionDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.CosmosDbSqlApiCollectionDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.CouchbaseTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.CustomDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.Db2TableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.DelimitedTextDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.DocumentDbCollectionDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.DrillTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.DynamicsAXResourceDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.DynamicsCrmEntityDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.DynamicsEntityDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.EloquaObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.ExcelDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.FileShareDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.GoogleAdWordsObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.GoogleBigQueryObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.GreenplumTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.HBaseObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.HiveObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.HttpDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.HubspotObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.ImpalaObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.InformixTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.JiraObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.JsonDataset; import com.microsoft.azure.management.datafactory.v2018_06_01.LinkedServiceReference; -import com.microsoft.azure.management.datafactory.v2018_06_01.MagentoObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.MariaDBTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.MarketoObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.MicrosoftAccessTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.MongoDbCollectionDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.MongoDbV2CollectionDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.MySqlTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.NetezzaTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.ODataResourceDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.OdbcTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.Office365Dataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.OracleServiceCloudObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.OracleTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.OrcDataset; import com.microsoft.azure.management.datafactory.v2018_06_01.ParameterSpecification; import java.util.List; import com.microsoft.azure.management.datafactory.v2018_06_01.DatasetFolder; @@ -77,38 +17,6 @@ import com.fasterxml.jackson.annotation.JsonTypeInfo; import com.fasterxml.jackson.annotation.JsonTypeName; import com.fasterxml.jackson.annotation.JsonSubTypes; -import com.microsoft.azure.management.datafactory.v2018_06_01.ParquetDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.PaypalObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.PhoenixObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.PostgreSqlTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.PrestoObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.QuickBooksObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.RelationalTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.ResponsysObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.RestResourceDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SalesforceMarketingCloudObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SalesforceObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SalesforceServiceCloudObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapBwCubeDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapCloudForCustomerResourceDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapEccResourceDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapHanaTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapOpenHubTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapTableResourceDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.ServiceNowObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SharePointOnlineListResourceDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.ShopifyObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SnowflakeDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SparkObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SqlServerTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SquareObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.SybaseTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.TeradataTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.VerticaTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.WebTableDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.XeroObjectDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.XmlDataset; -import com.microsoft.azure.management.datafactory.v2018_06_01.ZohoObjectDataset; /** * The Azure Data Factory nested object which identifies data within different diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlBatchResponseImpl.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlBatchResponseImpl.java new file mode 100644 index 0000000000000..66ce53b22aed9 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlBatchResponseImpl.java @@ -0,0 +1,32 @@ +/** + * 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.datafactory.v2018_06_01.implementation; + +import com.microsoft.azure.management.datafactory.v2018_06_01.ExposureControlBatchResponse; +import com.microsoft.azure.arm.model.implementation.WrapperImpl; +import java.util.List; + +class ExposureControlBatchResponseImpl extends WrapperImpl implements ExposureControlBatchResponse { + private final DataFactoryManager manager; + ExposureControlBatchResponseImpl(ExposureControlBatchResponseInner inner, DataFactoryManager manager) { + super(inner); + this.manager = manager; + } + + @Override + public DataFactoryManager manager() { + return this.manager; + } + + @Override + public List exposureControlResponses() { + return this.inner().exposureControlResponses(); + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlBatchResponseInner.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlBatchResponseInner.java new file mode 100644 index 0000000000000..6663333360238 --- /dev/null +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlBatchResponseInner.java @@ -0,0 +1,44 @@ +/** + * 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.datafactory.v2018_06_01.implementation; + +import java.util.List; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * A list of exposure control feature values. + */ +public class ExposureControlBatchResponseInner { + /** + * List of exposure control feature values. + */ + @JsonProperty(value = "exposureControlResponses", required = true) + private List exposureControlResponses; + + /** + * Get list of exposure control feature values. + * + * @return the exposureControlResponses value + */ + public List exposureControlResponses() { + return this.exposureControlResponses; + } + + /** + * Set list of exposure control feature values. + * + * @param exposureControlResponses the exposureControlResponses value to set + * @return the ExposureControlBatchResponseInner object itself. + */ + public ExposureControlBatchResponseInner withExposureControlResponses(List exposureControlResponses) { + this.exposureControlResponses = exposureControlResponses; + return this; + } + +} diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlsImpl.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlsImpl.java index f961241a30fd9..fa7d5b41b82cf 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlsImpl.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlsImpl.java @@ -15,6 +15,8 @@ import rx.Observable; import com.microsoft.azure.management.datafactory.v2018_06_01.ExposureControlResponse; import com.microsoft.azure.management.datafactory.v2018_06_01.ExposureControlRequest; +import com.microsoft.azure.management.datafactory.v2018_06_01.ExposureControlBatchResponse; +import java.util.List; class ExposureControlsImpl extends WrapperImpl implements ExposureControls { private final DataFactoryManager manager; @@ -52,4 +54,16 @@ public ExposureControlResponse call(ExposureControlResponseInner inner) { }); } + @Override + public Observable queryFeatureValuesByFactoryAsync(String resourceGroupName, String factoryName, List exposureControlRequests) { + ExposureControlsInner client = this.inner(); + return client.queryFeatureValuesByFactoryAsync(resourceGroupName, factoryName, exposureControlRequests) + .map(new Func1() { + @Override + public ExposureControlBatchResponse call(ExposureControlBatchResponseInner inner) { + return new ExposureControlBatchResponseImpl(inner, manager()); + } + }); + } + } diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlsInner.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlsInner.java index 1480ebb6a0067..477ae02b6b50a 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlsInner.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/ExposureControlsInner.java @@ -11,12 +11,14 @@ import retrofit2.Retrofit; import com.google.common.reflect.TypeToken; import com.microsoft.azure.CloudException; +import com.microsoft.azure.management.datafactory.v2018_06_01.ExposureControlBatchRequest; import com.microsoft.azure.management.datafactory.v2018_06_01.ExposureControlRequest; import com.microsoft.rest.ServiceCallback; import com.microsoft.rest.ServiceFuture; import com.microsoft.rest.ServiceResponse; import com.microsoft.rest.Validator; import java.io.IOException; +import java.util.List; import okhttp3.ResponseBody; import retrofit2.http.Body; import retrofit2.http.Header; @@ -62,6 +64,10 @@ interface ExposureControlsService { @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/getFeatureValue") Observable> getFeatureValueByFactory(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Query("api-version") String apiVersion, @Body ExposureControlRequest exposureControlRequest, @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.datafactory.v2018_06_01.ExposureControls queryFeatureValuesByFactory" }) + @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/queryFeaturesValue") + Observable> queryFeatureValuesByFactory(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Body ExposureControlBatchRequest exposureControlBatchRequest, @Header("User-Agent") String userAgent); + } /** @@ -245,4 +251,100 @@ private ServiceResponse getFeatureValueByFactoryDe .build(response); } + /** + * Get list of exposure control features for specific factory. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param exposureControlRequests List of exposure control features. + * @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 ExposureControlBatchResponseInner object if successful. + */ + public ExposureControlBatchResponseInner queryFeatureValuesByFactory(String resourceGroupName, String factoryName, List exposureControlRequests) { + return queryFeatureValuesByFactoryWithServiceResponseAsync(resourceGroupName, factoryName, exposureControlRequests).toBlocking().single().body(); + } + + /** + * Get list of exposure control features for specific factory. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param exposureControlRequests List of exposure control features. + * @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 queryFeatureValuesByFactoryAsync(String resourceGroupName, String factoryName, List exposureControlRequests, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(queryFeatureValuesByFactoryWithServiceResponseAsync(resourceGroupName, factoryName, exposureControlRequests), serviceCallback); + } + + /** + * Get list of exposure control features for specific factory. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param exposureControlRequests List of exposure control features. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the ExposureControlBatchResponseInner object + */ + public Observable queryFeatureValuesByFactoryAsync(String resourceGroupName, String factoryName, List exposureControlRequests) { + return queryFeatureValuesByFactoryWithServiceResponseAsync(resourceGroupName, factoryName, exposureControlRequests).map(new Func1, ExposureControlBatchResponseInner>() { + @Override + public ExposureControlBatchResponseInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Get list of exposure control features for specific factory. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param exposureControlRequests List of exposure control features. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the ExposureControlBatchResponseInner object + */ + public Observable> queryFeatureValuesByFactoryWithServiceResponseAsync(String resourceGroupName, String factoryName, List exposureControlRequests) { + 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 (this.client.apiVersion() == null) { + throw new IllegalArgumentException("Parameter this.client.apiVersion() is required and cannot be null."); + } + if (exposureControlRequests == null) { + throw new IllegalArgumentException("Parameter exposureControlRequests is required and cannot be null."); + } + Validator.validate(exposureControlRequests); + ExposureControlBatchRequest exposureControlBatchRequest = new ExposureControlBatchRequest(); + exposureControlBatchRequest.withExposureControlRequests(exposureControlRequests); + return service.queryFeatureValuesByFactory(this.client.subscriptionId(), resourceGroupName, factoryName, this.client.apiVersion(), this.client.acceptLanguage(), exposureControlBatchRequest, this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = queryFeatureValuesByFactoryDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse queryFeatureValuesByFactoryDelegate(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/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/IntegrationRuntimeInner.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/IntegrationRuntimeInner.java index 714c12e9db2ec..58b27acef3ca8 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/IntegrationRuntimeInner.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/IntegrationRuntimeInner.java @@ -13,8 +13,6 @@ import com.fasterxml.jackson.annotation.JsonTypeInfo; import com.fasterxml.jackson.annotation.JsonTypeName; import com.fasterxml.jackson.annotation.JsonSubTypes; -import com.microsoft.azure.management.datafactory.v2018_06_01.ManagedIntegrationRuntime; -import com.microsoft.azure.management.datafactory.v2018_06_01.SelfHostedIntegrationRuntime; /** * Azure Data Factory nested object which serves as a compute resource for diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/LinkedServiceInner.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/LinkedServiceInner.java index 17b7121541662..a11d27d96022e 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/LinkedServiceInner.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/LinkedServiceInner.java @@ -9,110 +9,13 @@ package com.microsoft.azure.management.datafactory.v2018_06_01.implementation; import java.util.Map; - -import com.microsoft.azure.management.datafactory.v2018_06_01.AmazonMWSLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AmazonRedshiftLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AmazonS3LinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureBatchLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureBlobFSLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureBlobStorageLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureDataExplorerLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureDataLakeAnalyticsLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureDataLakeStoreLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureDatabricksLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureFileStorageLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureFunctionLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureKeyVaultLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureMLLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureMLServiceLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureMariaDBLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureMySqlLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzurePostgreSqlLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureSearchLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureSqlDWLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureSqlDatabaseLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureSqlMILinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureStorageLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.AzureTableStorageLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.CassandraLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.CommonDataServiceForAppsLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.ConcurLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.CosmosDbLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.CosmosDbMongoDbApiLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.CouchbaseLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.CustomDataSourceLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.Db2LinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.DrillLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.DynamicsAXLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.DynamicsCrmLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.DynamicsLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.EloquaLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.FileServerLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.FtpServerLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.GoogleAdWordsLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.GoogleBigQueryLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.GoogleCloudStorageLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.GreenplumLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.HBaseLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.HDInsightLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.HDInsightOnDemandLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.HdfsLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.HiveLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.HttpLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.HubspotLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.ImpalaLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.InformixLinkedService; import com.microsoft.azure.management.datafactory.v2018_06_01.IntegrationRuntimeReference; -import com.microsoft.azure.management.datafactory.v2018_06_01.JiraLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.MagentoLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.MariaDBLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.MarketoLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.MicrosoftAccessLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.MongoDbLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.MongoDbV2LinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.MySqlLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.NetezzaLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.ODataLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.OdbcLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.Office365LinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.OracleLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.OracleServiceCloudLinkedService; import com.microsoft.azure.management.datafactory.v2018_06_01.ParameterSpecification; import java.util.List; import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonTypeInfo; import com.fasterxml.jackson.annotation.JsonTypeName; import com.fasterxml.jackson.annotation.JsonSubTypes; -import com.microsoft.azure.management.datafactory.v2018_06_01.PaypalLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.PhoenixLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.PostgreSqlLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.PrestoLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.QuickBooksLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.ResponsysLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.RestServiceLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SalesforceLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SalesforceMarketingCloudLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SalesforceServiceCloudLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapBWLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapCloudForCustomerLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapEccLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapHanaLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapOpenHubLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SapTableLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.ServiceNowLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SftpServerLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SharePointOnlineListLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.ShopifyLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SnowflakeLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SparkLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SqlServerLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SquareLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.SybaseLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.TeradataLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.VerticaLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.WebLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.XeroLinkedService; -import com.microsoft.azure.management.datafactory.v2018_06_01.ZohoLinkedService; /** * The Azure Data Factory nested object which contains the information and diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerInner.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerInner.java index 275a137e2dab6..d6a5e12c92a21 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerInner.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerInner.java @@ -9,17 +9,12 @@ package com.microsoft.azure.management.datafactory.v2018_06_01.implementation; import java.util.Map; - -import com.microsoft.azure.management.datafactory.v2018_06_01.ChainingTrigger; -import com.microsoft.azure.management.datafactory.v2018_06_01.MultiplePipelineTrigger; -import com.microsoft.azure.management.datafactory.v2018_06_01.RerunTumblingWindowTrigger; import com.microsoft.azure.management.datafactory.v2018_06_01.TriggerRuntimeState; import java.util.List; import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonTypeInfo; import com.fasterxml.jackson.annotation.JsonTypeName; import com.fasterxml.jackson.annotation.JsonSubTypes; -import com.microsoft.azure.management.datafactory.v2018_06_01.TumblingWindowTrigger; /** * Azure data factory nested object which contains information about creating diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerRunsImpl.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerRunsImpl.java index 4e6fce5927780..1c51eaf3394be 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerRunsImpl.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerRunsImpl.java @@ -35,6 +35,12 @@ public Completable rerunAsync(String resourceGroupName, String factoryName, Stri return client.rerunAsync(resourceGroupName, factoryName, triggerName, runId).toCompletable(); } + @Override + public Completable cancelAsync(String resourceGroupName, String factoryName, String triggerName, String runId) { + TriggerRunsInner client = this.inner(); + return client.cancelAsync(resourceGroupName, factoryName, triggerName, runId).toCompletable(); + } + @Override public Observable queryByFactoryAsync(String resourceGroupName, String factoryName, RunFilterParameters filterParameters) { TriggerRunsInner client = this.inner(); diff --git a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerRunsInner.java b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerRunsInner.java index 1ee31c0d96c82..90787d45e8c97 100644 --- a/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerRunsInner.java +++ b/sdk/datafactory/mgmt-v2018_06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggerRunsInner.java @@ -58,6 +58,10 @@ interface TriggerRunsService { @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/triggers/{triggerName}/triggerRuns/{runId}/rerun") Observable> rerun(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Path("triggerName") String triggerName, @Path("runId") String runId, @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.datafactory.v2018_06_01.TriggerRuns cancel" }) + @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/triggers/{triggerName}/triggerRuns/{runId}/cancel") + Observable> cancel(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Path("triggerName") String triggerName, @Path("runId") String runId, @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.datafactory.v2018_06_01.TriggerRuns queryByFactory" }) @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/queryTriggerRuns") Observable> queryByFactory(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Query("api-version") String apiVersion, @Body RunFilterParameters filterParameters, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); @@ -163,6 +167,105 @@ private ServiceResponse rerunDelegate(Response response) thr .build(response); } + /** + * Cancel a single trigger instance by runId. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param triggerName The trigger name. + * @param runId The pipeline run identifier. + * @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 cancel(String resourceGroupName, String factoryName, String triggerName, String runId) { + cancelWithServiceResponseAsync(resourceGroupName, factoryName, triggerName, runId).toBlocking().single().body(); + } + + /** + * Cancel a single trigger instance by runId. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param triggerName The trigger name. + * @param runId The pipeline run identifier. + * @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 cancelAsync(String resourceGroupName, String factoryName, String triggerName, String runId, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(cancelWithServiceResponseAsync(resourceGroupName, factoryName, triggerName, runId), serviceCallback); + } + + /** + * Cancel a single trigger instance by runId. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param triggerName The trigger name. + * @param runId The pipeline run identifier. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceResponse} object if successful. + */ + public Observable cancelAsync(String resourceGroupName, String factoryName, String triggerName, String runId) { + return cancelWithServiceResponseAsync(resourceGroupName, factoryName, triggerName, runId).map(new Func1, Void>() { + @Override + public Void call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Cancel a single trigger instance by runId. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param triggerName The trigger name. + * @param runId The pipeline run identifier. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the {@link ServiceResponse} object if successful. + */ + public Observable> cancelWithServiceResponseAsync(String resourceGroupName, String factoryName, String triggerName, String runId) { + 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 (triggerName == null) { + throw new IllegalArgumentException("Parameter triggerName is required and cannot be null."); + } + if (runId == null) { + throw new IllegalArgumentException("Parameter runId 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.cancel(this.client.subscriptionId(), resourceGroupName, factoryName, triggerName, runId, this.client.apiVersion(), this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = cancelDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse cancelDelegate(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); + } + /** * Query trigger runs. *