diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/CopySource.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/CopySource.java index 4a7334a37bc..91208044ba2 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/CopySource.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/CopySource.java @@ -21,6 +21,7 @@ @JsonTypeName("CopySource") @JsonSubTypes({ @JsonSubTypes.Type(name = "AmazonRedshiftSource", value = AmazonRedshiftSource.class), + @JsonSubTypes.Type(name = "ResponsysSource", value = ResponsysSource.class), @JsonSubTypes.Type(name = "SalesforceMarketingCloudSource", value = SalesforceMarketingCloudSource.class), @JsonSubTypes.Type(name = "VerticaSource", value = VerticaSource.class), @JsonSubTypes.Type(name = "NetezzaSource", value = NetezzaSource.class), diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/FactoryRepoUpdate.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/FactoryRepoUpdate.java new file mode 100644 index 00000000000..05ab71daa1d --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/FactoryRepoUpdate.java @@ -0,0 +1,95 @@ +/** + * 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; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Factory's VSTS repo information. + */ +public class FactoryRepoUpdate { + /** + * The factory resource id. + */ + @JsonProperty(value = "factoryResourceId") + private String factoryResourceId; + + /** + * The resource group name. + */ + @JsonProperty(value = "resourceGroupName") + private String resourceGroupName; + + /** + * VSTS repo information of the factory. + */ + @JsonProperty(value = "vstsConfiguration") + private FactoryVSTSConfiguration vstsConfiguration; + + /** + * Get the factoryResourceId value. + * + * @return the factoryResourceId value + */ + public String factoryResourceId() { + return this.factoryResourceId; + } + + /** + * Set the factoryResourceId value. + * + * @param factoryResourceId the factoryResourceId value to set + * @return the FactoryRepoUpdate object itself. + */ + public FactoryRepoUpdate withFactoryResourceId(String factoryResourceId) { + this.factoryResourceId = factoryResourceId; + return this; + } + + /** + * Get the resourceGroupName value. + * + * @return the resourceGroupName value + */ + public String resourceGroupName() { + return this.resourceGroupName; + } + + /** + * Set the resourceGroupName value. + * + * @param resourceGroupName the resourceGroupName value to set + * @return the FactoryRepoUpdate object itself. + */ + public FactoryRepoUpdate withResourceGroupName(String resourceGroupName) { + this.resourceGroupName = resourceGroupName; + return this; + } + + /** + * Get the vstsConfiguration value. + * + * @return the vstsConfiguration value + */ + public FactoryVSTSConfiguration vstsConfiguration() { + return this.vstsConfiguration; + } + + /** + * Set the vstsConfiguration value. + * + * @param vstsConfiguration the vstsConfiguration value to set + * @return the FactoryRepoUpdate object itself. + */ + public FactoryRepoUpdate withVstsConfiguration(FactoryVSTSConfiguration vstsConfiguration) { + this.vstsConfiguration = vstsConfiguration; + return this; + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/FactoryUpdateParameters.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/FactoryUpdateParameters.java new file mode 100644 index 00000000000..d9991da4d06 --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/FactoryUpdateParameters.java @@ -0,0 +1,70 @@ +/** + * 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; + +import java.util.Map; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Parameters for updating a factory resource. + */ +public class FactoryUpdateParameters { + /** + * The resource tags. + */ + @JsonProperty(value = "tags") + private Map tags; + + /** + * Managed service identity of the factory. + */ + @JsonProperty(value = "identity") + private FactoryIdentity identity; + + /** + * Get the tags value. + * + * @return the tags value + */ + public Map tags() { + return this.tags; + } + + /** + * Set the tags value. + * + * @param tags the tags value to set + * @return the FactoryUpdateParameters object itself. + */ + public FactoryUpdateParameters withTags(Map tags) { + this.tags = tags; + return this; + } + + /** + * Get the identity value. + * + * @return the identity value + */ + public FactoryIdentity identity() { + return this.identity; + } + + /** + * Set the identity value. + * + * @param identity the identity value to set + * @return the FactoryUpdateParameters object itself. + */ + public FactoryUpdateParameters withIdentity(FactoryIdentity identity) { + this.identity = identity; + return this; + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/FactoryVSTSConfiguration.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/FactoryVSTSConfiguration.java new file mode 100644 index 00000000000..1b3055ce62d --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/FactoryVSTSConfiguration.java @@ -0,0 +1,199 @@ +/** + * 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; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Factory's VSTS repo information. + */ +public class FactoryVSTSConfiguration { + /** + * VSTS account name. + */ + @JsonProperty(value = "accountName") + private String accountName; + + /** + * VSTS project name. + */ + @JsonProperty(value = "projectName") + private String projectName; + + /** + * VSTS repository name. + */ + @JsonProperty(value = "repositoryName") + private String repositoryName; + + /** + * VSTS collaboration branch. + */ + @JsonProperty(value = "collaborationBranch") + private String collaborationBranch; + + /** + * VSTS root folder. + */ + @JsonProperty(value = "rootFolder") + private String rootFolder; + + /** + * VSTS last commit id. + */ + @JsonProperty(value = "lastCommitId") + private String lastCommitId; + + /** + * VSTS tenant id. + */ + @JsonProperty(value = "tenantId") + private String tenantId; + + /** + * Get the accountName value. + * + * @return the accountName value + */ + public String accountName() { + return this.accountName; + } + + /** + * Set the accountName value. + * + * @param accountName the accountName value to set + * @return the FactoryVSTSConfiguration object itself. + */ + public FactoryVSTSConfiguration withAccountName(String accountName) { + this.accountName = accountName; + return this; + } + + /** + * Get the projectName value. + * + * @return the projectName value + */ + public String projectName() { + return this.projectName; + } + + /** + * Set the projectName value. + * + * @param projectName the projectName value to set + * @return the FactoryVSTSConfiguration object itself. + */ + public FactoryVSTSConfiguration withProjectName(String projectName) { + this.projectName = projectName; + return this; + } + + /** + * Get the repositoryName value. + * + * @return the repositoryName value + */ + public String repositoryName() { + return this.repositoryName; + } + + /** + * Set the repositoryName value. + * + * @param repositoryName the repositoryName value to set + * @return the FactoryVSTSConfiguration object itself. + */ + public FactoryVSTSConfiguration withRepositoryName(String repositoryName) { + this.repositoryName = repositoryName; + return this; + } + + /** + * Get the collaborationBranch value. + * + * @return the collaborationBranch value + */ + public String collaborationBranch() { + return this.collaborationBranch; + } + + /** + * Set the collaborationBranch value. + * + * @param collaborationBranch the collaborationBranch value to set + * @return the FactoryVSTSConfiguration object itself. + */ + public FactoryVSTSConfiguration withCollaborationBranch(String collaborationBranch) { + this.collaborationBranch = collaborationBranch; + return this; + } + + /** + * Get the rootFolder value. + * + * @return the rootFolder value + */ + public String rootFolder() { + return this.rootFolder; + } + + /** + * Set the rootFolder value. + * + * @param rootFolder the rootFolder value to set + * @return the FactoryVSTSConfiguration object itself. + */ + public FactoryVSTSConfiguration withRootFolder(String rootFolder) { + this.rootFolder = rootFolder; + return this; + } + + /** + * Get the lastCommitId value. + * + * @return the lastCommitId value + */ + public String lastCommitId() { + return this.lastCommitId; + } + + /** + * Set the lastCommitId value. + * + * @param lastCommitId the lastCommitId value to set + * @return the FactoryVSTSConfiguration object itself. + */ + public FactoryVSTSConfiguration withLastCommitId(String lastCommitId) { + this.lastCommitId = lastCommitId; + return this; + } + + /** + * Get the tenantId value. + * + * @return the tenantId value + */ + public String tenantId() { + return this.tenantId; + } + + /** + * Set the tenantId value. + * + * @param tenantId the tenantId value to set + * @return the FactoryVSTSConfiguration object itself. + */ + public FactoryVSTSConfiguration withTenantId(String tenantId) { + this.tenantId = tenantId; + return this; + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/IntegrationRuntimeRemoveNodeRequest.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/IntegrationRuntimeRemoveNodeRequest.java new file mode 100644 index 00000000000..985e9aa547e --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/IntegrationRuntimeRemoveNodeRequest.java @@ -0,0 +1,70 @@ +/** + * 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; + +import java.util.Map; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Request to remove a node. + */ +public class IntegrationRuntimeRemoveNodeRequest { + /** + * Unmatched properties from the message are deserialized this collection. + */ + @JsonProperty(value = "") + private Map additionalProperties; + + /** + * The name of the node to be removed. + */ + @JsonProperty(value = "nodeName") + private String nodeName; + + /** + * Get the additionalProperties value. + * + * @return the additionalProperties value + */ + public Map additionalProperties() { + return this.additionalProperties; + } + + /** + * Set the additionalProperties value. + * + * @param additionalProperties the additionalProperties value to set + * @return the IntegrationRuntimeRemoveNodeRequest object itself. + */ + public IntegrationRuntimeRemoveNodeRequest withAdditionalProperties(Map additionalProperties) { + this.additionalProperties = additionalProperties; + return this; + } + + /** + * Get the nodeName value. + * + * @return the nodeName value + */ + public String nodeName() { + return this.nodeName; + } + + /** + * Set the nodeName value. + * + * @param nodeName the nodeName value to set + * @return the IntegrationRuntimeRemoveNodeRequest object itself. + */ + public IntegrationRuntimeRemoveNodeRequest withNodeName(String nodeName) { + this.nodeName = nodeName; + return this; + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/PipelineRunFilterParameters.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/PipelineRunFilterParameters.java new file mode 100644 index 00000000000..69407fbab20 --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/PipelineRunFilterParameters.java @@ -0,0 +1,152 @@ +/** + * 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; + +import org.joda.time.DateTime; +import java.util.List; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Query parameters for listing pipeline runs. + */ +public class PipelineRunFilterParameters { + /** + * The continuation token for getting the next page of results. Null for + * first page. + */ + @JsonProperty(value = "continuationToken") + private String continuationToken; + + /** + * The time at or after which the pipeline run event was updated in 'ISO + * 8601' format. + */ + @JsonProperty(value = "lastUpdatedAfter", required = true) + private DateTime lastUpdatedAfter; + + /** + * The time at or before which the pipeline run event was updated in 'ISO + * 8601' format. + */ + @JsonProperty(value = "lastUpdatedBefore", required = true) + private DateTime lastUpdatedBefore; + + /** + * List of filters. + */ + @JsonProperty(value = "filters") + private List filters; + + /** + * List of OrderBy option. + */ + @JsonProperty(value = "orderBy") + private List orderBy; + + /** + * Get the continuationToken value. + * + * @return the continuationToken value + */ + public String continuationToken() { + return this.continuationToken; + } + + /** + * Set the continuationToken value. + * + * @param continuationToken the continuationToken value to set + * @return the PipelineRunFilterParameters object itself. + */ + public PipelineRunFilterParameters withContinuationToken(String continuationToken) { + this.continuationToken = continuationToken; + return this; + } + + /** + * Get the lastUpdatedAfter value. + * + * @return the lastUpdatedAfter value + */ + public DateTime lastUpdatedAfter() { + return this.lastUpdatedAfter; + } + + /** + * Set the lastUpdatedAfter value. + * + * @param lastUpdatedAfter the lastUpdatedAfter value to set + * @return the PipelineRunFilterParameters object itself. + */ + public PipelineRunFilterParameters withLastUpdatedAfter(DateTime lastUpdatedAfter) { + this.lastUpdatedAfter = lastUpdatedAfter; + return this; + } + + /** + * Get the lastUpdatedBefore value. + * + * @return the lastUpdatedBefore value + */ + public DateTime lastUpdatedBefore() { + return this.lastUpdatedBefore; + } + + /** + * Set the lastUpdatedBefore value. + * + * @param lastUpdatedBefore the lastUpdatedBefore value to set + * @return the PipelineRunFilterParameters object itself. + */ + public PipelineRunFilterParameters withLastUpdatedBefore(DateTime lastUpdatedBefore) { + this.lastUpdatedBefore = lastUpdatedBefore; + return this; + } + + /** + * Get the filters value. + * + * @return the filters value + */ + public List filters() { + return this.filters; + } + + /** + * Set the filters value. + * + * @param filters the filters value to set + * @return the PipelineRunFilterParameters object itself. + */ + public PipelineRunFilterParameters withFilters(List filters) { + this.filters = filters; + return this; + } + + /** + * Get the orderBy value. + * + * @return the orderBy value + */ + public List orderBy() { + return this.orderBy; + } + + /** + * Set the orderBy value. + * + * @param orderBy the orderBy value to set + * @return the PipelineRunFilterParameters object itself. + */ + public PipelineRunFilterParameters withOrderBy(List orderBy) { + this.orderBy = orderBy; + return this; + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/ResponsysLinkedService.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/ResponsysLinkedService.java new file mode 100644 index 00000000000..0f0bca45a06 --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/ResponsysLinkedService.java @@ -0,0 +1,217 @@ +/** + * 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; + +import com.fasterxml.jackson.annotation.JsonProperty; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import com.fasterxml.jackson.annotation.JsonTypeName; +import com.microsoft.rest.serializer.JsonFlatten; +import com.microsoft.azure.management.datafactory.implementation.LinkedServiceInner; + +/** + * Responsys linked service. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") +@JsonTypeName("Responsys") +@JsonFlatten +public class ResponsysLinkedService extends LinkedServiceInner { + /** + * The endpoint of the Responsys server. + */ + @JsonProperty(value = "typeProperties.endpoint", required = true) + private Object endpoint; + + /** + * The client ID associated with the Responsys application. Type: string + * (or Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.clientId", required = true) + private Object clientId; + + /** + * The client secret associated with the Responsys application. Type: + * string (or Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.clientSecret") + private SecretBase clientSecret; + + /** + * Specifies whether the data source endpoints are encrypted using HTTPS. + * The default value is true. Type: boolean (or Expression with resultType + * boolean). + */ + @JsonProperty(value = "typeProperties.useEncryptedEndpoints") + private Object useEncryptedEndpoints; + + /** + * Specifies whether to require the host name in the server's certificate + * to match the host name of the server when connecting over SSL. The + * default value is true. Type: boolean (or Expression with resultType + * boolean). + */ + @JsonProperty(value = "typeProperties.useHostVerification") + private Object useHostVerification; + + /** + * Specifies whether to verify the identity of the server when connecting + * over SSL. The default value is true. Type: boolean (or Expression with + * resultType boolean). + */ + @JsonProperty(value = "typeProperties.usePeerVerification") + private Object usePeerVerification; + + /** + * The encrypted credential used for authentication. Credentials are + * encrypted using the integration runtime credential manager. Type: string + * (or Expression with resultType string). + */ + @JsonProperty(value = "typeProperties.encryptedCredential") + private Object encryptedCredential; + + /** + * Get the endpoint value. + * + * @return the endpoint value + */ + public Object endpoint() { + return this.endpoint; + } + + /** + * Set the endpoint value. + * + * @param endpoint the endpoint value to set + * @return the ResponsysLinkedService object itself. + */ + public ResponsysLinkedService withEndpoint(Object endpoint) { + this.endpoint = endpoint; + return this; + } + + /** + * Get the clientId value. + * + * @return the clientId value + */ + public Object clientId() { + return this.clientId; + } + + /** + * Set the clientId value. + * + * @param clientId the clientId value to set + * @return the ResponsysLinkedService object itself. + */ + public ResponsysLinkedService withClientId(Object clientId) { + this.clientId = clientId; + return this; + } + + /** + * Get the clientSecret value. + * + * @return the clientSecret value + */ + public SecretBase clientSecret() { + return this.clientSecret; + } + + /** + * Set the clientSecret value. + * + * @param clientSecret the clientSecret value to set + * @return the ResponsysLinkedService object itself. + */ + public ResponsysLinkedService withClientSecret(SecretBase clientSecret) { + this.clientSecret = clientSecret; + return this; + } + + /** + * Get the useEncryptedEndpoints value. + * + * @return the useEncryptedEndpoints value + */ + public Object useEncryptedEndpoints() { + return this.useEncryptedEndpoints; + } + + /** + * Set the useEncryptedEndpoints value. + * + * @param useEncryptedEndpoints the useEncryptedEndpoints value to set + * @return the ResponsysLinkedService object itself. + */ + public ResponsysLinkedService withUseEncryptedEndpoints(Object useEncryptedEndpoints) { + this.useEncryptedEndpoints = useEncryptedEndpoints; + return this; + } + + /** + * Get the useHostVerification value. + * + * @return the useHostVerification value + */ + public Object useHostVerification() { + return this.useHostVerification; + } + + /** + * Set the useHostVerification value. + * + * @param useHostVerification the useHostVerification value to set + * @return the ResponsysLinkedService object itself. + */ + public ResponsysLinkedService withUseHostVerification(Object useHostVerification) { + this.useHostVerification = useHostVerification; + return this; + } + + /** + * Get the usePeerVerification value. + * + * @return the usePeerVerification value + */ + public Object usePeerVerification() { + return this.usePeerVerification; + } + + /** + * Set the usePeerVerification value. + * + * @param usePeerVerification the usePeerVerification value to set + * @return the ResponsysLinkedService object itself. + */ + public ResponsysLinkedService withUsePeerVerification(Object usePeerVerification) { + this.usePeerVerification = usePeerVerification; + return this; + } + + /** + * Get the encryptedCredential value. + * + * @return the encryptedCredential value + */ + public Object encryptedCredential() { + return this.encryptedCredential; + } + + /** + * Set the encryptedCredential value. + * + * @param encryptedCredential the encryptedCredential value to set + * @return the ResponsysLinkedService object itself. + */ + public ResponsysLinkedService withEncryptedCredential(Object encryptedCredential) { + this.encryptedCredential = encryptedCredential; + return this; + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/ResponsysObjectDataset.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/ResponsysObjectDataset.java new file mode 100644 index 00000000000..2a8a7d3c4b8 --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/ResponsysObjectDataset.java @@ -0,0 +1,21 @@ +/** + * 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; + +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import com.fasterxml.jackson.annotation.JsonTypeName; +import com.microsoft.azure.management.datafactory.implementation.DatasetInner; + +/** + * Responsys dataset. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") +@JsonTypeName("ResponsysObject") +public class ResponsysObjectDataset extends DatasetInner { +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/ResponsysSource.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/ResponsysSource.java new file mode 100644 index 00000000000..84b7a583a4d --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/ResponsysSource.java @@ -0,0 +1,48 @@ +/** + * 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; + +import com.fasterxml.jackson.annotation.JsonProperty; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import com.fasterxml.jackson.annotation.JsonTypeName; + +/** + * A copy activity Responsys source. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") +@JsonTypeName("ResponsysSource") +public class ResponsysSource extends CopySource { + /** + * A query to retrieve data from source. Type: string (or Expression with + * resultType string). + */ + @JsonProperty(value = "query") + private Object query; + + /** + * Get the query value. + * + * @return the query value + */ + public Object query() { + return this.query; + } + + /** + * Set the query value. + * + * @param query the query value to set + * @return the ResponsysSource object itself. + */ + public ResponsysSource withQuery(Object query) { + this.query = query; + return this; + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/UpdateIntegrationRuntimeRequest.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/UpdateIntegrationRuntimeRequest.java new file mode 100644 index 00000000000..4b049f2f458 --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/UpdateIntegrationRuntimeRequest.java @@ -0,0 +1,72 @@ +/** + * 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; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Update integration runtime request. + */ +public class UpdateIntegrationRuntimeRequest { + /** + * Enables or disables the auto-update feature of the self-hosted + * integration runtime. See https://go.microsoft.com/fwlink/?linkid=854189. + * Possible values include: 'On', 'Off'. + */ + @JsonProperty(value = "autoUpdate") + private IntegrationRuntimeAutoUpdate autoUpdate; + + /** + * The time offset (in hours) in the day, e.g., PT03H is 3 hours. The + * integration runtime auto update will happen on that time. + */ + @JsonProperty(value = "updateDelayOffset") + private String updateDelayOffset; + + /** + * Get the autoUpdate value. + * + * @return the autoUpdate value + */ + public IntegrationRuntimeAutoUpdate autoUpdate() { + return this.autoUpdate; + } + + /** + * Set the autoUpdate value. + * + * @param autoUpdate the autoUpdate value to set + * @return the UpdateIntegrationRuntimeRequest object itself. + */ + public UpdateIntegrationRuntimeRequest withAutoUpdate(IntegrationRuntimeAutoUpdate autoUpdate) { + this.autoUpdate = autoUpdate; + return this; + } + + /** + * Get the updateDelayOffset value. + * + * @return the updateDelayOffset value + */ + public String updateDelayOffset() { + return this.updateDelayOffset; + } + + /** + * Set the updateDelayOffset value. + * + * @param updateDelayOffset the updateDelayOffset value to set + * @return the UpdateIntegrationRuntimeRequest object itself. + */ + public UpdateIntegrationRuntimeRequest withUpdateDelayOffset(String updateDelayOffset) { + this.updateDelayOffset = updateDelayOffset; + return this; + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/ConfigureFactoryReposInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/ConfigureFactoryReposInner.java new file mode 100644 index 00000000000..22fa6f96a42 --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/ConfigureFactoryReposInner.java @@ -0,0 +1,149 @@ +/** + * 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.implementation; + +import retrofit2.Retrofit; +import com.google.common.reflect.TypeToken; +import com.microsoft.azure.management.datafactory.ErrorResponseException; +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 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 ConfigureFactoryRepos. + */ +public class ConfigureFactoryReposInner { + /** The Retrofit service to perform REST calls. */ + private ConfigureFactoryReposService service; + /** The service client containing this operation class. */ + private DataFactoryManagementClientImpl client; + + /** + * Initializes an instance of ConfigureFactoryReposInner. + * + * @param retrofit the Retrofit instance built from a Retrofit Builder. + * @param client the instance of the service client containing this operation class. + */ + public ConfigureFactoryReposInner(Retrofit retrofit, DataFactoryManagementClientImpl client) { + this.service = retrofit.create(ConfigureFactoryReposService.class); + this.client = client; + } + + /** + * The interface defining all the services for ConfigureFactoryRepos to be + * used by Retrofit to perform actually REST calls. + */ + interface ConfigureFactoryReposService { + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactory.ConfigureFactoryRepos update" }) + @POST("subscriptions/{subscriptionId}/providers/Microsoft.DataFactory/locations/{locationId}/configureFactoryRepo") + Observable> update(@Path("subscriptionId") String subscriptionId, @Path("locationId") String locationId, @Query("api-version") String apiVersion, @Body FactoryRepoUpdateInner factoryRepoUpdate, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + } + + /** + * Updates a factory's repo information. + * + * @param locationId The location identifier. + * @param factoryRepoUpdate Update factory repo request definition. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the FactoryInner object if successful. + */ + public FactoryInner update(String locationId, FactoryRepoUpdateInner factoryRepoUpdate) { + return updateWithServiceResponseAsync(locationId, factoryRepoUpdate).toBlocking().single().body(); + } + + /** + * Updates a factory's repo information. + * + * @param locationId The location identifier. + * @param factoryRepoUpdate Update factory repo request definition. + * @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 updateAsync(String locationId, FactoryRepoUpdateInner factoryRepoUpdate, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(updateWithServiceResponseAsync(locationId, factoryRepoUpdate), serviceCallback); + } + + /** + * Updates a factory's repo information. + * + * @param locationId The location identifier. + * @param factoryRepoUpdate Update factory repo request definition. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the FactoryInner object + */ + public Observable updateAsync(String locationId, FactoryRepoUpdateInner factoryRepoUpdate) { + return updateWithServiceResponseAsync(locationId, factoryRepoUpdate).map(new Func1, FactoryInner>() { + @Override + public FactoryInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Updates a factory's repo information. + * + * @param locationId The location identifier. + * @param factoryRepoUpdate Update factory repo request definition. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the FactoryInner object + */ + public Observable> updateWithServiceResponseAsync(String locationId, FactoryRepoUpdateInner factoryRepoUpdate) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (locationId == null) { + throw new IllegalArgumentException("Parameter locationId 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 (factoryRepoUpdate == null) { + throw new IllegalArgumentException("Parameter factoryRepoUpdate is required and cannot be null."); + } + Validator.validate(factoryRepoUpdate); + return service.update(this.client.subscriptionId(), locationId, this.client.apiVersion(), factoryRepoUpdate, this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = updateDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse updateDelegate(Response response) throws ErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken() { }.getType()) + .registerError(ErrorResponseException.class) + .build(response); + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/ConfigureReposInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/ConfigureReposInner.java new file mode 100644 index 00000000000..af99ce05fe2 --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/ConfigureReposInner.java @@ -0,0 +1,156 @@ +/** + * 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.implementation; + +import retrofit2.Retrofit; +import com.google.common.reflect.TypeToken; +import com.microsoft.azure.management.datafactory.ErrorResponseException; +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 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 ConfigureRepos. + */ +public class ConfigureReposInner { + /** The Retrofit service to perform REST calls. */ + private ConfigureReposService service; + /** The service client containing this operation class. */ + private DataFactoryManagementClientImpl client; + + /** + * Initializes an instance of ConfigureReposInner. + * + * @param retrofit the Retrofit instance built from a Retrofit Builder. + * @param client the instance of the service client containing this operation class. + */ + public ConfigureReposInner(Retrofit retrofit, DataFactoryManagementClientImpl client) { + this.service = retrofit.create(ConfigureReposService.class); + this.client = client; + } + + /** + * The interface defining all the services for ConfigureRepos to be + * used by Retrofit to perform actually REST calls. + */ + interface ConfigureReposService { + @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactory.ConfigureRepos update" }) + @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/configureRepo") + Observable> update(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Query("api-version") String apiVersion, @Body FactoryRepoUpdateInner factoryRepoUpdate, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + + } + + /** + * Updates a factory's repo information. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param factoryRepoUpdate Update factory repo request definition. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @throws ErrorResponseException thrown if the request is rejected by server + * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent + * @return the FactoryInner object if successful. + */ + public FactoryInner update(String resourceGroupName, String factoryName, FactoryRepoUpdateInner factoryRepoUpdate) { + return updateWithServiceResponseAsync(resourceGroupName, factoryName, factoryRepoUpdate).toBlocking().single().body(); + } + + /** + * Updates a factory's repo information. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param factoryRepoUpdate Update factory repo request definition. + * @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 updateAsync(String resourceGroupName, String factoryName, FactoryRepoUpdateInner factoryRepoUpdate, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(updateWithServiceResponseAsync(resourceGroupName, factoryName, factoryRepoUpdate), serviceCallback); + } + + /** + * Updates a factory's repo information. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param factoryRepoUpdate Update factory repo request definition. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the FactoryInner object + */ + public Observable updateAsync(String resourceGroupName, String factoryName, FactoryRepoUpdateInner factoryRepoUpdate) { + return updateWithServiceResponseAsync(resourceGroupName, factoryName, factoryRepoUpdate).map(new Func1, FactoryInner>() { + @Override + public FactoryInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Updates a factory's repo information. + * + * @param resourceGroupName The resource group name. + * @param factoryName The factory name. + * @param factoryRepoUpdate Update factory repo request definition. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the FactoryInner object + */ + public Observable> updateWithServiceResponseAsync(String resourceGroupName, String factoryName, FactoryRepoUpdateInner factoryRepoUpdate) { + 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 (factoryRepoUpdate == null) { + throw new IllegalArgumentException("Parameter factoryRepoUpdate is required and cannot be null."); + } + Validator.validate(factoryRepoUpdate); + return service.update(this.client.subscriptionId(), resourceGroupName, factoryName, this.client.apiVersion(), factoryRepoUpdate, this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = updateDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse updateDelegate(Response response) throws ErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken() { }.getType()) + .registerError(ErrorResponseException.class) + .build(response); + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/DatasetInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/DatasetInner.java index 491dccd044b..af5c571852d 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/DatasetInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/DatasetInner.java @@ -24,6 +24,7 @@ @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") @JsonTypeName("Dataset") @JsonSubTypes({ + @JsonSubTypes.Type(name = "ResponsysObject", value = ResponsysObjectDataset.class), @JsonSubTypes.Type(name = "SalesforceMarketingCloudObject", value = SalesforceMarketingCloudObjectDataset.class), @JsonSubTypes.Type(name = "VerticaTable", value = VerticaTableDataset.class), @JsonSubTypes.Type(name = "NetezzaTable", value = NetezzaTableDataset.class), diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/DatasetResourceInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/DatasetResourceInner.java index 8dd1a994ab6..15b109f3e86 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/DatasetResourceInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/DatasetResourceInner.java @@ -21,6 +21,24 @@ public class DatasetResourceInner extends SubResource { @JsonProperty(value = "properties", required = true) private DatasetInner properties; + /** + * The resource name. + */ + @JsonProperty(value = "name", access = JsonProperty.Access.WRITE_ONLY) + private String name; + + /** + * The resource type. + */ + @JsonProperty(value = "type", access = JsonProperty.Access.WRITE_ONLY) + private String type; + + /** + * Etag identifies change in the resource. + */ + @JsonProperty(value = "etag", access = JsonProperty.Access.WRITE_ONLY) + private String etag; + /** * Get the properties value. * @@ -41,4 +59,31 @@ public DatasetResourceInner withProperties(DatasetInner properties) { return this; } + /** + * Get the name value. + * + * @return the name value + */ + public String name() { + return this.name; + } + + /** + * Get the type value. + * + * @return the type value + */ + public String type() { + return this.type; + } + + /** + * Get the etag value. + * + * @return the etag value + */ + public String etag() { + return this.etag; + } + } diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoriesInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoriesInner.java index f80b7d93c88..6b32a24c11e 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoriesInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoriesInner.java @@ -16,6 +16,8 @@ import com.microsoft.azure.AzureServiceFuture; import com.microsoft.azure.ListOperationCallback; import com.microsoft.azure.management.datafactory.ErrorResponseException; +import com.microsoft.azure.management.datafactory.FactoryRepoUpdate; +import com.microsoft.azure.management.datafactory.FactoryUpdateParameters; import com.microsoft.azure.Page; import com.microsoft.azure.PagedList; import com.microsoft.rest.ServiceCallback; @@ -70,6 +72,10 @@ interface FactoriesService { @GET("subscriptions/{subscriptionId}/providers/Microsoft.DataFactory/factories") Observable> list(@Path("subscriptionId") String subscriptionId, @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.Factories configureFactoryRepo" }) + @POST("subscriptions/{subscriptionId}/providers/Microsoft.DataFactory/locations/{locationId}/configureFactoryRepo") + Observable> configureFactoryRepo(@Path("subscriptionId") String subscriptionId, @Path("locationId") String locationId, @Query("api-version") String apiVersion, @Body FactoryRepoUpdate factoryRepoUpdate, @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.Factories listByResourceGroup" }) @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories") Observable> listByResourceGroup(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Query("api-version") String apiVersion, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); @@ -80,7 +86,7 @@ interface FactoriesService { @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactory.Factories update" }) @PATCH("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}") - Observable> update(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Query("api-version") String apiVersion, @Body FactoryUpdateParametersInner factoryUpdateParameters, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + Observable> update(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Query("api-version") String apiVersion, @Body FactoryUpdateParameters factoryUpdateParameters, @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.Factories getByResourceGroup" }) @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}") @@ -211,6 +217,93 @@ private ServiceResponse> listDelegate(Response configureFactoryRepoAsync(String locationId, FactoryRepoUpdate factoryRepoUpdate, final ServiceCallback serviceCallback) { + return ServiceFuture.fromResponse(configureFactoryRepoWithServiceResponseAsync(locationId, factoryRepoUpdate), serviceCallback); + } + + /** + * Updates a factory's repo information. + * + * @param locationId The location identifier. + * @param factoryRepoUpdate Update factory repo request definition. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the FactoryInner object + */ + public Observable configureFactoryRepoAsync(String locationId, FactoryRepoUpdate factoryRepoUpdate) { + return configureFactoryRepoWithServiceResponseAsync(locationId, factoryRepoUpdate).map(new Func1, FactoryInner>() { + @Override + public FactoryInner call(ServiceResponse response) { + return response.body(); + } + }); + } + + /** + * Updates a factory's repo information. + * + * @param locationId The location identifier. + * @param factoryRepoUpdate Update factory repo request definition. + * @throws IllegalArgumentException thrown if parameters fail the validation + * @return the observable to the FactoryInner object + */ + public Observable> configureFactoryRepoWithServiceResponseAsync(String locationId, FactoryRepoUpdate factoryRepoUpdate) { + if (this.client.subscriptionId() == null) { + throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); + } + if (locationId == null) { + throw new IllegalArgumentException("Parameter locationId 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 (factoryRepoUpdate == null) { + throw new IllegalArgumentException("Parameter factoryRepoUpdate is required and cannot be null."); + } + Validator.validate(factoryRepoUpdate); + return service.configureFactoryRepo(this.client.subscriptionId(), locationId, this.client.apiVersion(), factoryRepoUpdate, this.client.acceptLanguage(), this.client.userAgent()) + .flatMap(new Func1, Observable>>() { + @Override + public Observable> call(Response response) { + try { + ServiceResponse clientResponse = configureFactoryRepoDelegate(response); + return Observable.just(clientResponse); + } catch (Throwable t) { + return Observable.error(t); + } + } + }); + } + + private ServiceResponse configureFactoryRepoDelegate(Response response) throws ErrorResponseException, IOException, IllegalArgumentException { + return this.client.restClient().responseBuilderFactory().newInstance(this.client.serializerAdapter()) + .register(200, new TypeToken() { }.getType()) + .registerError(ErrorResponseException.class) + .build(response); + } + /** * Lists factories. * @@ -431,7 +524,7 @@ private ServiceResponse createOrUpdateDelegate(Response updateAsync(String resourceGroupName, String factoryName, FactoryUpdateParametersInner factoryUpdateParameters, final ServiceCallback serviceCallback) { + public ServiceFuture updateAsync(String resourceGroupName, String factoryName, FactoryUpdateParameters factoryUpdateParameters, final ServiceCallback serviceCallback) { return ServiceFuture.fromResponse(updateWithServiceResponseAsync(resourceGroupName, factoryName, factoryUpdateParameters), serviceCallback); } @@ -458,7 +551,7 @@ public ServiceFuture updateAsync(String resourceGroupName, String * @throws IllegalArgumentException thrown if parameters fail the validation * @return the observable to the FactoryInner object */ - public Observable updateAsync(String resourceGroupName, String factoryName, FactoryUpdateParametersInner factoryUpdateParameters) { + public Observable updateAsync(String resourceGroupName, String factoryName, FactoryUpdateParameters factoryUpdateParameters) { return updateWithServiceResponseAsync(resourceGroupName, factoryName, factoryUpdateParameters).map(new Func1, FactoryInner>() { @Override public FactoryInner call(ServiceResponse response) { @@ -476,7 +569,7 @@ public FactoryInner call(ServiceResponse response) { * @throws IllegalArgumentException thrown if parameters fail the validation * @return the observable to the FactoryInner object */ - public Observable> updateWithServiceResponseAsync(String resourceGroupName, String factoryName, FactoryUpdateParametersInner factoryUpdateParameters) { + public Observable> updateWithServiceResponseAsync(String resourceGroupName, String factoryName, FactoryUpdateParameters factoryUpdateParameters) { if (this.client.subscriptionId() == null) { throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); } diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoryInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoryInner.java index d8347b4ae10..ada87a5d81c 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoryInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoryInner.java @@ -11,14 +11,17 @@ import java.util.Map; import com.microsoft.azure.management.datafactory.FactoryIdentity; import org.joda.time.DateTime; +import com.microsoft.azure.management.datafactory.FactoryVSTSConfiguration; import com.fasterxml.jackson.annotation.JsonProperty; import com.microsoft.rest.serializer.JsonFlatten; +import com.microsoft.rest.SkipParentValidation; import com.microsoft.azure.Resource; /** * Factory resource type. */ @JsonFlatten +@SkipParentValidation public class FactoryInner extends Resource { /** * Unmatched properties from the message are deserialized this collection. @@ -50,6 +53,12 @@ public class FactoryInner extends Resource { @JsonProperty(value = "properties.version", access = JsonProperty.Access.WRITE_ONLY) private String version; + /** + * VSTS repo information of the factory. + */ + @JsonProperty(value = "properties.vstsConfiguration") + private FactoryVSTSConfiguration vstsConfiguration; + /** * Get the additionalProperties value. * @@ -117,4 +126,24 @@ public String version() { return this.version; } + /** + * Get the vstsConfiguration value. + * + * @return the vstsConfiguration value + */ + public FactoryVSTSConfiguration vstsConfiguration() { + return this.vstsConfiguration; + } + + /** + * Set the vstsConfiguration value. + * + * @param vstsConfiguration the vstsConfiguration value to set + * @return the FactoryInner object itself. + */ + public FactoryInner withVstsConfiguration(FactoryVSTSConfiguration vstsConfiguration) { + this.vstsConfiguration = vstsConfiguration; + return this; + } + } diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoryRepoUpdateInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoryRepoUpdateInner.java new file mode 100644 index 00000000000..a127a1965bb --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/FactoryRepoUpdateInner.java @@ -0,0 +1,96 @@ +/** + * 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.implementation; + +import com.microsoft.azure.management.datafactory.FactoryVSTSConfiguration; +import com.fasterxml.jackson.annotation.JsonProperty; + +/** + * Factory's VSTS repo information. + */ +public class FactoryRepoUpdateInner { + /** + * The factory resource id. + */ + @JsonProperty(value = "factoryResourceId") + private String factoryResourceId; + + /** + * The resource group name. + */ + @JsonProperty(value = "resourceGroupName") + private String resourceGroupName; + + /** + * VSTS repo information of the factory. + */ + @JsonProperty(value = "vstsConfiguration") + private FactoryVSTSConfiguration vstsConfiguration; + + /** + * Get the factoryResourceId value. + * + * @return the factoryResourceId value + */ + public String factoryResourceId() { + return this.factoryResourceId; + } + + /** + * Set the factoryResourceId value. + * + * @param factoryResourceId the factoryResourceId value to set + * @return the FactoryRepoUpdateInner object itself. + */ + public FactoryRepoUpdateInner withFactoryResourceId(String factoryResourceId) { + this.factoryResourceId = factoryResourceId; + return this; + } + + /** + * Get the resourceGroupName value. + * + * @return the resourceGroupName value + */ + public String resourceGroupName() { + return this.resourceGroupName; + } + + /** + * Set the resourceGroupName value. + * + * @param resourceGroupName the resourceGroupName value to set + * @return the FactoryRepoUpdateInner object itself. + */ + public FactoryRepoUpdateInner withResourceGroupName(String resourceGroupName) { + this.resourceGroupName = resourceGroupName; + return this; + } + + /** + * Get the vstsConfiguration value. + * + * @return the vstsConfiguration value + */ + public FactoryVSTSConfiguration vstsConfiguration() { + return this.vstsConfiguration; + } + + /** + * Set the vstsConfiguration value. + * + * @param vstsConfiguration the vstsConfiguration value to set + * @return the FactoryRepoUpdateInner object itself. + */ + public FactoryRepoUpdateInner withVstsConfiguration(FactoryVSTSConfiguration vstsConfiguration) { + this.vstsConfiguration = vstsConfiguration; + return this; + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/IntegrationRuntimeResourceInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/IntegrationRuntimeResourceInner.java index 85be83055c3..b4e64519e11 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/IntegrationRuntimeResourceInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/IntegrationRuntimeResourceInner.java @@ -21,6 +21,24 @@ public class IntegrationRuntimeResourceInner extends SubResource { @JsonProperty(value = "properties", required = true) private IntegrationRuntimeInner properties; + /** + * The resource name. + */ + @JsonProperty(value = "name", access = JsonProperty.Access.WRITE_ONLY) + private String name; + + /** + * The resource type. + */ + @JsonProperty(value = "type", access = JsonProperty.Access.WRITE_ONLY) + private String type; + + /** + * Etag identifies change in the resource. + */ + @JsonProperty(value = "etag", access = JsonProperty.Access.WRITE_ONLY) + private String etag; + /** * Get the properties value. * @@ -41,4 +59,31 @@ public IntegrationRuntimeResourceInner withProperties(IntegrationRuntimeInner pr return this; } + /** + * Get the name value. + * + * @return the name value + */ + public String name() { + return this.name; + } + + /** + * Get the type value. + * + * @return the type value + */ + public String type() { + return this.type; + } + + /** + * Get the etag value. + * + * @return the etag value + */ + public String etag() { + return this.etag; + } + } diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/IntegrationRuntimesInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/IntegrationRuntimesInner.java index ad93a5538d5..41ca85591f5 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/IntegrationRuntimesInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/IntegrationRuntimesInner.java @@ -15,6 +15,8 @@ import com.microsoft.azure.management.datafactory.ErrorResponseException; import com.microsoft.azure.management.datafactory.IntegrationRuntimeAuthKeyName; import com.microsoft.azure.management.datafactory.IntegrationRuntimeRegenerateKeyParameters; +import com.microsoft.azure.management.datafactory.IntegrationRuntimeRemoveNodeRequest; +import com.microsoft.azure.management.datafactory.UpdateIntegrationRuntimeRequest; import com.microsoft.azure.Page; import com.microsoft.azure.PagedList; import com.microsoft.rest.ServiceCallback; @@ -79,7 +81,7 @@ interface IntegrationRuntimesService { @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactory.IntegrationRuntimes update" }) @PATCH("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/integrationRuntimes/{integrationRuntimeName}") - Observable> update(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Path("integrationRuntimeName") String integrationRuntimeName, @Query("api-version") String apiVersion, @Body UpdateIntegrationRuntimeRequestInner updateIntegrationRuntimeRequest, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + Observable> update(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Path("integrationRuntimeName") String integrationRuntimeName, @Query("api-version") String apiVersion, @Body UpdateIntegrationRuntimeRequest updateIntegrationRuntimeRequest, @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.IntegrationRuntimes delete" }) @HTTP(path = "subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/integrationRuntimes/{integrationRuntimeName}", method = "DELETE", hasBody = true) @@ -119,7 +121,7 @@ interface IntegrationRuntimesService { @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactory.IntegrationRuntimes removeNode" }) @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/integrationRuntimes/{integrationRuntimeName}/removeNode") - Observable> removeNode(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Path("integrationRuntimeName") String integrationRuntimeName, @Query("api-version") String apiVersion, @Body IntegrationRuntimeRemoveNodeRequestInner removeNodeParameters, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + Observable> removeNode(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Path("integrationRuntimeName") String integrationRuntimeName, @Query("api-version") String apiVersion, @Body IntegrationRuntimeRemoveNodeRequest removeNodeParameters, @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.IntegrationRuntimes syncCredentials" }) @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/integrationRuntimes/{integrationRuntimeName}/syncCredentials") @@ -571,7 +573,7 @@ private ServiceResponse getDelegate(Response updateAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, UpdateIntegrationRuntimeRequestInner updateIntegrationRuntimeRequest, final ServiceCallback serviceCallback) { + public ServiceFuture updateAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, UpdateIntegrationRuntimeRequest updateIntegrationRuntimeRequest, final ServiceCallback serviceCallback) { return ServiceFuture.fromResponse(updateWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName, updateIntegrationRuntimeRequest), serviceCallback); } @@ -600,7 +602,7 @@ public ServiceFuture updateAsync(String r * @throws IllegalArgumentException thrown if parameters fail the validation * @return the observable to the IntegrationRuntimeStatusResponseInner object */ - public Observable updateAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, UpdateIntegrationRuntimeRequestInner updateIntegrationRuntimeRequest) { + public Observable updateAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, UpdateIntegrationRuntimeRequest updateIntegrationRuntimeRequest) { return updateWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName, updateIntegrationRuntimeRequest).map(new Func1, IntegrationRuntimeStatusResponseInner>() { @Override public IntegrationRuntimeStatusResponseInner call(ServiceResponse response) { @@ -619,7 +621,7 @@ public IntegrationRuntimeStatusResponseInner call(ServiceResponse> updateWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, UpdateIntegrationRuntimeRequestInner updateIntegrationRuntimeRequest) { + public Observable> updateWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, UpdateIntegrationRuntimeRequest updateIntegrationRuntimeRequest) { if (this.client.subscriptionId() == null) { throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); } @@ -1569,7 +1571,7 @@ private ServiceResponse beginStopDelegate(Response response) * @throws ErrorResponseException thrown if the request is rejected by server * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent */ - public void removeNode(String resourceGroupName, String factoryName, String integrationRuntimeName, IntegrationRuntimeRemoveNodeRequestInner removeNodeParameters) { + public void removeNode(String resourceGroupName, String factoryName, String integrationRuntimeName, IntegrationRuntimeRemoveNodeRequest removeNodeParameters) { removeNodeWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName, removeNodeParameters).toBlocking().single().body(); } @@ -1584,7 +1586,7 @@ public void removeNode(String resourceGroupName, String factoryName, String inte * @throws IllegalArgumentException thrown if parameters fail the validation * @return the {@link ServiceFuture} object */ - public ServiceFuture removeNodeAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, IntegrationRuntimeRemoveNodeRequestInner removeNodeParameters, final ServiceCallback serviceCallback) { + public ServiceFuture removeNodeAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, IntegrationRuntimeRemoveNodeRequest removeNodeParameters, final ServiceCallback serviceCallback) { return ServiceFuture.fromResponse(removeNodeWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName, removeNodeParameters), serviceCallback); } @@ -1598,7 +1600,7 @@ public ServiceFuture removeNodeAsync(String resourceGroupName, String fact * @throws IllegalArgumentException thrown if parameters fail the validation * @return the {@link ServiceResponse} object if successful. */ - public Observable removeNodeAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, IntegrationRuntimeRemoveNodeRequestInner removeNodeParameters) { + public Observable removeNodeAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, IntegrationRuntimeRemoveNodeRequest removeNodeParameters) { return removeNodeWithServiceResponseAsync(resourceGroupName, factoryName, integrationRuntimeName, removeNodeParameters).map(new Func1, Void>() { @Override public Void call(ServiceResponse response) { @@ -1617,7 +1619,7 @@ public Void call(ServiceResponse response) { * @throws IllegalArgumentException thrown if parameters fail the validation * @return the {@link ServiceResponse} object if successful. */ - public Observable> removeNodeWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, IntegrationRuntimeRemoveNodeRequestInner removeNodeParameters) { + public Observable> removeNodeWithServiceResponseAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, IntegrationRuntimeRemoveNodeRequest removeNodeParameters) { if (this.client.subscriptionId() == null) { throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); } diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/LinkedServiceInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/LinkedServiceInner.java index 40459fafaa9..9473ea37c81 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/LinkedServiceInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/LinkedServiceInner.java @@ -25,6 +25,7 @@ @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") @JsonTypeName("LinkedService") @JsonSubTypes({ + @JsonSubTypes.Type(name = "Responsys", value = ResponsysLinkedService.class), @JsonSubTypes.Type(name = "AzureDatabricks", value = AzureDatabricksLinkedService.class), @JsonSubTypes.Type(name = "AzureDataLakeAnalytics", value = AzureDataLakeAnalyticsLinkedService.class), @JsonSubTypes.Type(name = "HDInsightOnDemand", value = HDInsightOnDemandLinkedService.class), diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/LinkedServiceResourceInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/LinkedServiceResourceInner.java index 35e7a5fd5bd..1a4a0daf55b 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/LinkedServiceResourceInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/LinkedServiceResourceInner.java @@ -21,6 +21,24 @@ public class LinkedServiceResourceInner extends SubResource { @JsonProperty(value = "properties", required = true) private LinkedServiceInner properties; + /** + * The resource name. + */ + @JsonProperty(value = "name", access = JsonProperty.Access.WRITE_ONLY) + private String name; + + /** + * The resource type. + */ + @JsonProperty(value = "type", access = JsonProperty.Access.WRITE_ONLY) + private String type; + + /** + * Etag identifies change in the resource. + */ + @JsonProperty(value = "etag", access = JsonProperty.Access.WRITE_ONLY) + private String etag; + /** * Get the properties value. * @@ -41,4 +59,31 @@ public LinkedServiceResourceInner withProperties(LinkedServiceInner properties) return this; } + /** + * Get the name value. + * + * @return the name value + */ + public String name() { + return this.name; + } + + /** + * Get the type value. + * + * @return the type value + */ + public String type() { + return this.type; + } + + /** + * Get the etag value. + * + * @return the etag value + */ + public String etag() { + return this.etag; + } + } diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/OperationInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/OperationInner.java new file mode 100644 index 00000000000..689f666675e --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/OperationInner.java @@ -0,0 +1,125 @@ +/** + * 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.implementation; + +import com.microsoft.azure.management.datafactory.OperationDisplay; +import com.microsoft.azure.management.datafactory.OperationServiceSpecification; +import com.fasterxml.jackson.annotation.JsonProperty; +import com.microsoft.rest.serializer.JsonFlatten; + +/** + * Azure Data Factory API operation definition. + */ +@JsonFlatten +public class OperationInner { + /** + * Operation name: {provider}/{resource}/{operation}. + */ + @JsonProperty(value = "name") + private String name; + + /** + * The intended executor of the operation. + */ + @JsonProperty(value = "origin") + private String origin; + + /** + * Metadata associated with the operation. + */ + @JsonProperty(value = "display") + private OperationDisplay display; + + /** + * Details about a service operation. + */ + @JsonProperty(value = "properties.serviceSpecification") + private OperationServiceSpecification serviceSpecification; + + /** + * Get the name value. + * + * @return the name value + */ + public String name() { + return this.name; + } + + /** + * Set the name value. + * + * @param name the name value to set + * @return the OperationInner object itself. + */ + public OperationInner withName(String name) { + this.name = name; + return this; + } + + /** + * Get the origin value. + * + * @return the origin value + */ + public String origin() { + return this.origin; + } + + /** + * Set the origin value. + * + * @param origin the origin value to set + * @return the OperationInner object itself. + */ + public OperationInner withOrigin(String origin) { + this.origin = origin; + return this; + } + + /** + * Get the display value. + * + * @return the display value + */ + public OperationDisplay display() { + return this.display; + } + + /** + * Set the display value. + * + * @param display the display value to set + * @return the OperationInner object itself. + */ + public OperationInner withDisplay(OperationDisplay display) { + this.display = display; + return this; + } + + /** + * Get the serviceSpecification value. + * + * @return the serviceSpecification value + */ + public OperationServiceSpecification serviceSpecification() { + return this.serviceSpecification; + } + + /** + * Set the serviceSpecification value. + * + * @param serviceSpecification the serviceSpecification value to set + * @return the OperationInner object itself. + */ + public OperationInner withServiceSpecification(OperationServiceSpecification serviceSpecification) { + this.serviceSpecification = serviceSpecification; + return this; + } + +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/OperationListResponseInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/OperationListResponseInner.java index a826a965662..30ef5fb625d 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/OperationListResponseInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/OperationListResponseInner.java @@ -9,7 +9,6 @@ package com.microsoft.azure.management.datafactory.implementation; import java.util.List; -import com.microsoft.azure.management.datafactory.Operation; import com.fasterxml.jackson.annotation.JsonProperty; /** @@ -21,7 +20,7 @@ public class OperationListResponseInner { * provider. */ @JsonProperty(value = "value") - private List value; + private List value; /** * The link to the next page of results, if any remaining results exist. @@ -34,7 +33,7 @@ public class OperationListResponseInner { * * @return the value value */ - public List value() { + public List value() { return this.value; } @@ -44,7 +43,7 @@ public List value() { * @param value the value value to set * @return the OperationListResponseInner object itself. */ - public OperationListResponseInner withValue(List value) { + public OperationListResponseInner withValue(List value) { this.value = value; return this; } diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/PipelineResourceInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/PipelineResourceInner.java index b5214b92ff8..3adc7270750 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/PipelineResourceInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/PipelineResourceInner.java @@ -57,6 +57,24 @@ public class PipelineResourceInner extends SubResource { @JsonProperty(value = "properties.annotations") private List annotations; + /** + * The resource name. + */ + @JsonProperty(value = "name", access = JsonProperty.Access.WRITE_ONLY) + private String name; + + /** + * The resource type. + */ + @JsonProperty(value = "type", access = JsonProperty.Access.WRITE_ONLY) + private String type; + + /** + * Etag identifies change in the resource. + */ + @JsonProperty(value = "etag", access = JsonProperty.Access.WRITE_ONLY) + private String etag; + /** * Get the additionalProperties value. * @@ -177,4 +195,31 @@ public PipelineResourceInner withAnnotations(List annotations) { return this; } + /** + * Get the name value. + * + * @return the name value + */ + public String name() { + return this.name; + } + + /** + * Get the type value. + * + * @return the type value + */ + public String type() { + return this.type; + } + + /** + * Get the etag value. + * + * @return the etag value + */ + public String etag() { + return this.etag; + } + } diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/PipelineRunsInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/PipelineRunsInner.java index 5ff3ad91b15..b3f0e78cf38 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/PipelineRunsInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/PipelineRunsInner.java @@ -11,6 +11,7 @@ import retrofit2.Retrofit; import com.google.common.reflect.TypeToken; import com.microsoft.azure.management.datafactory.ErrorResponseException; +import com.microsoft.azure.management.datafactory.PipelineRunFilterParameters; import com.microsoft.rest.ServiceCallback; import com.microsoft.rest.ServiceFuture; import com.microsoft.rest.ServiceResponse; @@ -56,7 +57,7 @@ public PipelineRunsInner(Retrofit retrofit, DataFactoryManagementClientImpl clie interface PipelineRunsService { @Headers({ "Content-Type: application/json; charset=utf-8", "x-ms-logging-context: com.microsoft.azure.management.datafactory.PipelineRuns queryByFactory" }) @POST("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/pipelineruns") - Observable> queryByFactory(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Query("api-version") String apiVersion, @Body PipelineRunFilterParametersInner filterParameters, @Header("accept-language") String acceptLanguage, @Header("User-Agent") String userAgent); + Observable> queryByFactory(@Path("subscriptionId") String subscriptionId, @Path("resourceGroupName") String resourceGroupName, @Path("factoryName") String factoryName, @Query("api-version") String apiVersion, @Body PipelineRunFilterParameters filterParameters, @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.PipelineRuns get" }) @GET("subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/pipelineruns/{runId}") @@ -75,7 +76,7 @@ interface PipelineRunsService { * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent * @return the PipelineRunQueryResponseInner object if successful. */ - public PipelineRunQueryResponseInner queryByFactory(String resourceGroupName, String factoryName, PipelineRunFilterParametersInner filterParameters) { + public PipelineRunQueryResponseInner queryByFactory(String resourceGroupName, String factoryName, PipelineRunFilterParameters filterParameters) { return queryByFactoryWithServiceResponseAsync(resourceGroupName, factoryName, filterParameters).toBlocking().single().body(); } @@ -89,7 +90,7 @@ public PipelineRunQueryResponseInner queryByFactory(String resourceGroupName, St * @throws IllegalArgumentException thrown if parameters fail the validation * @return the {@link ServiceFuture} object */ - public ServiceFuture queryByFactoryAsync(String resourceGroupName, String factoryName, PipelineRunFilterParametersInner filterParameters, final ServiceCallback serviceCallback) { + public ServiceFuture queryByFactoryAsync(String resourceGroupName, String factoryName, PipelineRunFilterParameters filterParameters, final ServiceCallback serviceCallback) { return ServiceFuture.fromResponse(queryByFactoryWithServiceResponseAsync(resourceGroupName, factoryName, filterParameters), serviceCallback); } @@ -102,7 +103,7 @@ public ServiceFuture queryByFactoryAsync(String r * @throws IllegalArgumentException thrown if parameters fail the validation * @return the observable to the PipelineRunQueryResponseInner object */ - public Observable queryByFactoryAsync(String resourceGroupName, String factoryName, PipelineRunFilterParametersInner filterParameters) { + public Observable queryByFactoryAsync(String resourceGroupName, String factoryName, PipelineRunFilterParameters filterParameters) { return queryByFactoryWithServiceResponseAsync(resourceGroupName, factoryName, filterParameters).map(new Func1, PipelineRunQueryResponseInner>() { @Override public PipelineRunQueryResponseInner call(ServiceResponse response) { @@ -120,7 +121,7 @@ public PipelineRunQueryResponseInner call(ServiceResponse> queryByFactoryWithServiceResponseAsync(String resourceGroupName, String factoryName, PipelineRunFilterParametersInner filterParameters) { + public Observable> queryByFactoryWithServiceResponseAsync(String resourceGroupName, String factoryName, PipelineRunFilterParameters filterParameters) { if (this.client.subscriptionId() == null) { throw new IllegalArgumentException("Parameter this.client.subscriptionId() is required and cannot be null."); } diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/TriggerResourceInner.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/TriggerResourceInner.java index 3fa6209dd91..434bcbd1da4 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/TriggerResourceInner.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/implementation/TriggerResourceInner.java @@ -21,6 +21,24 @@ public class TriggerResourceInner extends SubResource { @JsonProperty(value = "properties", required = true) private TriggerInner properties; + /** + * The resource name. + */ + @JsonProperty(value = "name", access = JsonProperty.Access.WRITE_ONLY) + private String name; + + /** + * The resource type. + */ + @JsonProperty(value = "type", access = JsonProperty.Access.WRITE_ONLY) + private String type; + + /** + * Etag identifies change in the resource. + */ + @JsonProperty(value = "etag", access = JsonProperty.Access.WRITE_ONLY) + private String etag; + /** * Get the properties value. * @@ -41,4 +59,31 @@ public TriggerResourceInner withProperties(TriggerInner properties) { return this; } + /** + * Get the name value. + * + * @return the name value + */ + public String name() { + return this.name; + } + + /** + * Get the type value. + * + * @return the type value + */ + public String type() { + return this.type; + } + + /** + * Get the etag value. + * + * @return the etag value + */ + public String etag() { + return this.etag; + } + }