diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/BlobEventTypes.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/BlobEventTypes.java new file mode 100644 index 00000000000..c04507ce7a0 --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/BlobEventTypes.java @@ -0,0 +1,41 @@ +/** + * 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.Collection; +import com.fasterxml.jackson.annotation.JsonCreator; +import com.microsoft.rest.ExpandableStringEnum; + +/** + * Defines values for BlobEventTypes. + */ +public final class BlobEventTypes extends ExpandableStringEnum { + /** Static value Microsoft.Storage.BlobCreated for BlobEventTypes. */ + public static final BlobEventTypes MICROSOFT_STORAGE_BLOB_CREATED = fromString("Microsoft.Storage.BlobCreated"); + + /** Static value Microsoft.Storage.BlobDeleted for BlobEventTypes. */ + public static final BlobEventTypes MICROSOFT_STORAGE_BLOB_DELETED = fromString("Microsoft.Storage.BlobDeleted"); + + /** + * Creates or finds a BlobEventTypes from its string representation. + * @param name a name to look for + * @return the corresponding BlobEventTypes + */ + @JsonCreator + public static BlobEventTypes fromString(String name) { + return fromString(name, BlobEventTypes.class); + } + + /** + * @return known BlobEventTypes values + */ + public static Collection values() { + return values(BlobEventTypes.class); + } +} diff --git a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/BlobEventsTrigger.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/BlobEventsTrigger.java new file mode 100644 index 00000000000..66408b8cd0d --- /dev/null +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/BlobEventsTrigger.java @@ -0,0 +1,134 @@ +/** + * 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.List; +import com.fasterxml.jackson.annotation.JsonProperty; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import com.fasterxml.jackson.annotation.JsonTypeName; +import com.microsoft.rest.serializer.JsonFlatten; + +/** + * Trigger that runs everytime a Blob event occurs. + */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") +@JsonTypeName("BlobEventsTrigger") +@JsonFlatten +public class BlobEventsTrigger extends MultiplePipelineTrigger { + /** + * The blob path must begin with the pattern provided for trigger to fire. + * For example, '/records/blobs/december/' will only fire the trigger for + * blobs in the december folder under the records container. At least one + * of these must be provided: blobPathBeginsWith, blobPathEndsWith. + */ + @JsonProperty(value = "typeProperties.blobPathBeginsWith") + private String blobPathBeginsWith; + + /** + * The blob path must end with the pattern provided for trigger to fire. + * For example, 'december/boxes.csv' will only fire the trigger for blobs + * named boxes in a december folder. At least one of these must be + * provided: blobPathBeginsWith, blobPathEndsWith. + */ + @JsonProperty(value = "typeProperties.blobPathEndsWith") + private String blobPathEndsWith; + + /** + * The type of events that cause this trigger to fire. + */ + @JsonProperty(value = "typeProperties.events", required = true) + private List events; + + /** + * The ARM resource ID of the Storage Account. + */ + @JsonProperty(value = "typeProperties.scope", required = true) + private String scope; + + /** + * Get the blobPathBeginsWith value. + * + * @return the blobPathBeginsWith value + */ + public String blobPathBeginsWith() { + return this.blobPathBeginsWith; + } + + /** + * Set the blobPathBeginsWith value. + * + * @param blobPathBeginsWith the blobPathBeginsWith value to set + * @return the BlobEventsTrigger object itself. + */ + public BlobEventsTrigger withBlobPathBeginsWith(String blobPathBeginsWith) { + this.blobPathBeginsWith = blobPathBeginsWith; + return this; + } + + /** + * Get the blobPathEndsWith value. + * + * @return the blobPathEndsWith value + */ + public String blobPathEndsWith() { + return this.blobPathEndsWith; + } + + /** + * Set the blobPathEndsWith value. + * + * @param blobPathEndsWith the blobPathEndsWith value to set + * @return the BlobEventsTrigger object itself. + */ + public BlobEventsTrigger withBlobPathEndsWith(String blobPathEndsWith) { + this.blobPathEndsWith = blobPathEndsWith; + return this; + } + + /** + * Get the events value. + * + * @return the events value + */ + public List events() { + return this.events; + } + + /** + * Set the events value. + * + * @param events the events value to set + * @return the BlobEventsTrigger object itself. + */ + public BlobEventsTrigger withEvents(List events) { + this.events = events; + return this; + } + + /** + * Get the scope value. + * + * @return the scope value + */ + public String scope() { + return this.scope; + } + + /** + * Set the scope value. + * + * @param scope the scope value to set + * @return the BlobEventsTrigger object itself. + */ + public BlobEventsTrigger withScope(String scope) { + this.scope = scope; + 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/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/MultiplePipelineTrigger.java b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/MultiplePipelineTrigger.java index c565b998923..c87b6586f12 100644 --- a/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/MultiplePipelineTrigger.java +++ b/azure-mgmt-datafactory/src/main/java/com/microsoft/azure/management/datafactory/MultiplePipelineTrigger.java @@ -22,6 +22,7 @@ @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") @JsonTypeName("MultiplePipelineTrigger") @JsonSubTypes({ + @JsonSubTypes.Type(name = "BlobEventsTrigger", value = BlobEventsTrigger.class), @JsonSubTypes.Type(name = "BlobTrigger", value = BlobTrigger.class), @JsonSubTypes.Type(name = "ScheduleTrigger", value = ScheduleTrigger.class) }) 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/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/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..9053ca15a0f 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,7 @@ import com.microsoft.azure.AzureServiceFuture; import com.microsoft.azure.ListOperationCallback; import com.microsoft.azure.management.datafactory.ErrorResponseException; +import com.microsoft.azure.management.datafactory.FactoryUpdateParameters; import com.microsoft.azure.Page; import com.microsoft.azure.PagedList; import com.microsoft.rest.ServiceCallback; @@ -80,7 +81,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}") @@ -431,7 +432,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 +459,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 +477,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..3805920974f 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 @@ -13,12 +13,14 @@ import org.joda.time.DateTime; 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. 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/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; + } + }