diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/CHANGELOG.md b/sdk/datafactory/azure-resourcemanager-datafactory/CHANGELOG.md index e319f3071715..25e5b536eeda 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/CHANGELOG.md +++ b/sdk/datafactory/azure-resourcemanager-datafactory/CHANGELOG.md @@ -1,6 +1,8 @@ # Release History -## 1.0.0-beta.7 (Unreleased) +## 1.0.0-beta.1 (2021-11-10) + +- Azure Resource Manager DataFactory client library for Java. This package contains Microsoft Azure SDK for DataFactory Management SDK. The Azure Data Factory V2 management API provides a RESTful set of web services that interact with Azure Data Factory V2 services. Package tag package-2018-06. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt). ### Features Added diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/README.md b/sdk/datafactory/azure-resourcemanager-datafactory/README.md index 3c566d23d8d9..85035c9bd16b 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/README.md +++ b/sdk/datafactory/azure-resourcemanager-datafactory/README.md @@ -32,7 +32,7 @@ Various documentation is available to help you get started com.azure.resourcemanager azure-resourcemanager-datafactory - 1.0.0-beta.6 + 1.0.0-beta.7 ``` [//]: # ({x-version-update-end}) diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md b/sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md index d3f9ab5854b1..1e7d8a825bfa 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md +++ b/sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md @@ -521,8 +521,7 @@ public final class DataFlowsCreateOrUpdateSamples { + " string,CurrentConversionRate as double),allowSchemaDrift: true,validateSchema: false)" + " ~> CADSource\n" + "USDCurrency, CADSource union(byName: true)~> Union\n" - + "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~>" - + " NewCurrencyColumn\n" + + "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn\n" + "NewCurrencyColumn split(Country == 'USD',Country == 'CAD',disjoint: false) ~>" + " ConditionalSplit1@(USD, CAD)\n" + "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink\n" @@ -577,8 +576,7 @@ public final class DataFlowsCreateOrUpdateSamples { + " string,CurrentConversionRate as double),allowSchemaDrift: true,validateSchema: false)" + " ~> CADSource\n" + "USDCurrency, CADSource union(byName: true)~> Union\n" - + "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~>" - + " NewCurrencyColumn\n" + + "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn\n" + "NewCurrencyColumn split(Country == 'USD',Country == 'CAD',disjoint: false) ~>" + " ConditionalSplit1@(USD, CAD)\n" + "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink\n" diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/pom.xml b/sdk/datafactory/azure-resourcemanager-datafactory/pom.xml index 56df78c01b1f..a9f19c0b8bc0 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/pom.xml +++ b/sdk/datafactory/azure-resourcemanager-datafactory/pom.xml @@ -38,7 +38,10 @@ UTF-8 - + true + false + + @@ -84,14 +87,6 @@ - - org.jacoco - jacoco-maven-plugin - 0.8.7 - - true - - org.revapi revapi-maven-plugin diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/DataFactoryManager.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/DataFactoryManager.java index ddf5a0ae2f2d..8eed8312d398 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/DataFactoryManager.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/DataFactoryManager.java @@ -8,6 +8,7 @@ import com.azure.core.http.HttpClient; import com.azure.core.http.HttpPipeline; import com.azure.core.http.HttpPipelineBuilder; +import com.azure.core.http.HttpPipelinePosition; import com.azure.core.http.policy.AddDatePolicy; import com.azure.core.http.policy.HttpLogOptions; import com.azure.core.http.policy.HttpLoggingPolicy; @@ -67,6 +68,7 @@ import java.util.ArrayList; import java.util.List; import java.util.Objects; +import java.util.stream.Collectors; /** * Entry point to DataFactoryManager. The Azure Data Factory V2 management API provides a RESTful set of web services @@ -249,7 +251,7 @@ public DataFactoryManager authenticate(TokenCredential credential, AzureProfile .append("-") .append("com.azure.resourcemanager.datafactory") .append("/") - .append("1.0.0-beta.6"); + .append("1.0.0-beta.1"); if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) { userAgentBuilder .append(" (") @@ -272,11 +274,24 @@ public DataFactoryManager authenticate(TokenCredential credential, AzureProfile List policies = new ArrayList<>(); policies.add(new UserAgentPolicy(userAgentBuilder.toString())); policies.add(new RequestIdPolicy()); + policies + .addAll( + this + .policies + .stream() + .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL) + .collect(Collectors.toList())); HttpPolicyProviders.addBeforeRetryPolicies(policies); policies.add(retryPolicy); policies.add(new AddDatePolicy()); policies.add(new ArmChallengeAuthenticationPolicy(credential, scopes.toArray(new String[0]))); - policies.addAll(this.policies); + policies + .addAll( + this + .policies + .stream() + .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY) + .collect(Collectors.toList())); HttpPolicyProviders.addAfterRetryPolicies(policies); policies.add(new HttpLoggingPolicy(httpLogOptions)); HttpPipeline httpPipeline = diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/DataFlowDebugSessionsClient.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/DataFlowDebugSessionsClient.java index 8205f72b9282..3a74ffc1acd7 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/DataFlowDebugSessionsClient.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/DataFlowDebugSessionsClient.java @@ -33,7 +33,7 @@ public interface DataFlowDebugSessionsClient { * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure for creating data flow debug session. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, CreateDataFlowDebugSessionResponseInner> beginCreate(String resourceGroupName, String factoryName, CreateDataFlowDebugSessionRequest request); @@ -49,7 +49,7 @@ public interface DataFlowDebugSessionsClient { * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure for creating data flow debug session. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, CreateDataFlowDebugSessionResponseInner> beginCreate( String resourceGroupName, String factoryName, CreateDataFlowDebugSessionRequest request, Context context); @@ -184,7 +184,7 @@ Response deleteWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure of data flow result for data preview, statistics or expression preview. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DataFlowDebugCommandResponseInner> beginExecuteCommand( String resourceGroupName, String factoryName, DataFlowDebugCommandRequest request); @@ -200,7 +200,7 @@ SyncPoller, DataFlowDebugCommandRe * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure of data flow result for data preview, statistics or expression preview. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, DataFlowDebugCommandResponseInner> beginExecuteCommand( String resourceGroupName, String factoryName, DataFlowDebugCommandRequest request, Context context); diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/IntegrationRuntimeObjectMetadatasClient.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/IntegrationRuntimeObjectMetadatasClient.java index a998271c4ed4..761810fe3535 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/IntegrationRuntimeObjectMetadatasClient.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/IntegrationRuntimeObjectMetadatasClient.java @@ -29,7 +29,7 @@ public interface IntegrationRuntimeObjectMetadatasClient { * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the status of the operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, SsisObjectMetadataStatusResponseInner> beginRefresh( String resourceGroupName, String factoryName, String integrationRuntimeName); @@ -45,7 +45,7 @@ SyncPoller, SsisObjectMetadata * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the status of the operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, SsisObjectMetadataStatusResponseInner> beginRefresh( String resourceGroupName, String factoryName, String integrationRuntimeName, Context context); diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/IntegrationRuntimesClient.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/IntegrationRuntimesClient.java index deff3644c05c..f23eea26a020 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/IntegrationRuntimesClient.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/IntegrationRuntimesClient.java @@ -380,7 +380,7 @@ Response listAuthKeysWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return integration runtime status response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, IntegrationRuntimeStatusResponseInner> beginStart( String resourceGroupName, String factoryName, String integrationRuntimeName); @@ -396,7 +396,7 @@ SyncPoller, IntegrationRuntime * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return integration runtime status response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, IntegrationRuntimeStatusResponseInner> beginStart( String resourceGroupName, String factoryName, String integrationRuntimeName, Context context); @@ -442,7 +442,7 @@ IntegrationRuntimeStatusResponseInner start( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginStop( String resourceGroupName, String factoryName, String integrationRuntimeName); @@ -458,7 +458,7 @@ SyncPoller, Void> beginStop( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginStop( String resourceGroupName, String factoryName, String integrationRuntimeName, Context context); diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/TriggersClient.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/TriggersClient.java index b016c07d0dbb..7941482ae770 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/TriggersClient.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/TriggersClient.java @@ -188,7 +188,7 @@ Response deleteWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, TriggerSubscriptionOperationStatusInner> beginSubscribeToEvents(String resourceGroupName, String factoryName, String triggerName); @@ -204,7 +204,7 @@ Response deleteWithResponse( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, TriggerSubscriptionOperationStatusInner> beginSubscribeToEvents(String resourceGroupName, String factoryName, String triggerName, Context context); @@ -281,7 +281,7 @@ Response getEventSubscriptionStatusWith * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, TriggerSubscriptionOperationStatusInner> beginUnsubscribeFromEvents(String resourceGroupName, String factoryName, String triggerName); @@ -297,7 +297,7 @@ Response getEventSubscriptionStatusWith * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, TriggerSubscriptionOperationStatusInner> beginUnsubscribeFromEvents(String resourceGroupName, String factoryName, String triggerName, Context context); @@ -343,7 +343,7 @@ TriggerSubscriptionOperationStatusInner unsubscribeFromEvents( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginStart(String resourceGroupName, String factoryName, String triggerName); /** @@ -358,7 +358,7 @@ TriggerSubscriptionOperationStatusInner unsubscribeFromEvents( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginStart( String resourceGroupName, String factoryName, String triggerName, Context context); @@ -400,7 +400,7 @@ SyncPoller, Void> beginStart( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginStop(String resourceGroupName, String factoryName, String triggerName); /** @@ -415,7 +415,7 @@ SyncPoller, Void> beginStart( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) SyncPoller, Void> beginStop( String resourceGroupName, String factoryName, String triggerName, Context context); diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/ExecutePowerQueryActivityTypeProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/ExecutePowerQueryActivityTypeProperties.java index 42fc84ab19b1..83165b1a3afe 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/ExecutePowerQueryActivityTypeProperties.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/ExecutePowerQueryActivityTypeProperties.java @@ -11,9 +11,11 @@ import com.azure.resourcemanager.datafactory.models.ExecuteDataFlowActivityTypePropertiesCompute; import com.azure.resourcemanager.datafactory.models.IntegrationRuntimeReference; import com.azure.resourcemanager.datafactory.models.PowerQuerySink; +import com.azure.resourcemanager.datafactory.models.PowerQuerySinkMapping; import com.fasterxml.jackson.annotation.JsonIgnore; import com.fasterxml.jackson.annotation.JsonInclude; import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.List; import java.util.Map; /** Execute power query data flow activity properties. */ @@ -22,14 +24,22 @@ public final class ExecutePowerQueryActivityTypeProperties extends ExecuteDataFl @JsonIgnore private final ClientLogger logger = new ClientLogger(ExecutePowerQueryActivityTypeProperties.class); /* - * List of Power Query activity sinks mapped to a queryName. + * (Deprecated. Please use Queries). List of Power Query activity sinks + * mapped to a queryName. */ @JsonProperty(value = "sinks") @JsonInclude(value = JsonInclude.Include.NON_NULL, content = JsonInclude.Include.ALWAYS) private Map sinks; + /* + * List of mapping for Power Query mashup query to sink dataset(s). + */ + @JsonProperty(value = "queries") + private List queries; + /** - * Get the sinks property: List of Power Query activity sinks mapped to a queryName. + * Get the sinks property: (Deprecated. Please use Queries). List of Power Query activity sinks mapped to a + * queryName. * * @return the sinks value. */ @@ -38,7 +48,8 @@ public Map sinks() { } /** - * Set the sinks property: List of Power Query activity sinks mapped to a queryName. + * Set the sinks property: (Deprecated. Please use Queries). List of Power Query activity sinks mapped to a + * queryName. * * @param sinks the sinks value to set. * @return the ExecutePowerQueryActivityTypeProperties object itself. @@ -48,6 +59,26 @@ public ExecutePowerQueryActivityTypeProperties withSinks(Map queries() { + return this.queries; + } + + /** + * Set the queries property: List of mapping for Power Query mashup query to sink dataset(s). + * + * @param queries the queries value to set. + * @return the ExecutePowerQueryActivityTypeProperties object itself. + */ + public ExecutePowerQueryActivityTypeProperties withQueries(List queries) { + this.queries = queries; + return this; + } + /** {@inheritDoc} */ @Override public ExecutePowerQueryActivityTypeProperties withDataFlow(DataFlowReference dataFlow) { @@ -116,5 +147,8 @@ public void validate() { } }); } + if (queries() != null) { + queries().forEach(e -> e.validate()); + } } } diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FlowletTypeProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FlowletTypeProperties.java new file mode 100644 index 000000000000..4c590f2b6f44 --- /dev/null +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FlowletTypeProperties.java @@ -0,0 +1,193 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. +// Code generated by Microsoft (R) AutoRest Code Generator. + +package com.azure.resourcemanager.datafactory.fluent.models; + +import com.azure.core.annotation.Fluent; +import com.azure.core.util.logging.ClientLogger; +import com.azure.resourcemanager.datafactory.models.DataFlowSink; +import com.azure.resourcemanager.datafactory.models.DataFlowSource; +import com.azure.resourcemanager.datafactory.models.Transformation; +import com.fasterxml.jackson.annotation.JsonIgnore; +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.List; + +/** Flowlet type properties. */ +@Fluent +public final class FlowletTypeProperties { + @JsonIgnore private final ClientLogger logger = new ClientLogger(FlowletTypeProperties.class); + + /* + * List of sources in Flowlet. + */ + @JsonProperty(value = "sources") + private List sources; + + /* + * List of sinks in Flowlet. + */ + @JsonProperty(value = "sinks") + private List sinks; + + /* + * List of transformations in Flowlet. + */ + @JsonProperty(value = "transformations") + private List transformations; + + /* + * Flowlet script. + */ + @JsonProperty(value = "script") + private String script; + + /* + * Flowlet script lines. + */ + @JsonProperty(value = "scriptLines") + private List scriptLines; + + /* + * Any object + */ + @JsonProperty(value = "additionalProperties") + private Object additionalProperties; + + /** + * Get the sources property: List of sources in Flowlet. + * + * @return the sources value. + */ + public List sources() { + return this.sources; + } + + /** + * Set the sources property: List of sources in Flowlet. + * + * @param sources the sources value to set. + * @return the FlowletTypeProperties object itself. + */ + public FlowletTypeProperties withSources(List sources) { + this.sources = sources; + return this; + } + + /** + * Get the sinks property: List of sinks in Flowlet. + * + * @return the sinks value. + */ + public List sinks() { + return this.sinks; + } + + /** + * Set the sinks property: List of sinks in Flowlet. + * + * @param sinks the sinks value to set. + * @return the FlowletTypeProperties object itself. + */ + public FlowletTypeProperties withSinks(List sinks) { + this.sinks = sinks; + return this; + } + + /** + * Get the transformations property: List of transformations in Flowlet. + * + * @return the transformations value. + */ + public List transformations() { + return this.transformations; + } + + /** + * Set the transformations property: List of transformations in Flowlet. + * + * @param transformations the transformations value to set. + * @return the FlowletTypeProperties object itself. + */ + public FlowletTypeProperties withTransformations(List transformations) { + this.transformations = transformations; + return this; + } + + /** + * Get the script property: Flowlet script. + * + * @return the script value. + */ + public String script() { + return this.script; + } + + /** + * Set the script property: Flowlet script. + * + * @param script the script value to set. + * @return the FlowletTypeProperties object itself. + */ + public FlowletTypeProperties withScript(String script) { + this.script = script; + return this; + } + + /** + * Get the scriptLines property: Flowlet script lines. + * + * @return the scriptLines value. + */ + public List scriptLines() { + return this.scriptLines; + } + + /** + * Set the scriptLines property: Flowlet script lines. + * + * @param scriptLines the scriptLines value to set. + * @return the FlowletTypeProperties object itself. + */ + public FlowletTypeProperties withScriptLines(List scriptLines) { + this.scriptLines = scriptLines; + return this; + } + + /** + * Get the additionalProperties property: Any object. + * + * @return the additionalProperties value. + */ + public Object additionalProperties() { + return this.additionalProperties; + } + + /** + * Set the additionalProperties property: Any object. + * + * @param additionalProperties the additionalProperties value to set. + * @return the FlowletTypeProperties object itself. + */ + public FlowletTypeProperties withAdditionalProperties(Object additionalProperties) { + this.additionalProperties = additionalProperties; + return this; + } + + /** + * Validates the instance. + * + * @throws IllegalArgumentException thrown if the instance is not valid. + */ + public void validate() { + if (sources() != null) { + sources().forEach(e -> e.validate()); + } + if (sinks() != null) { + sinks().forEach(e -> e.validate()); + } + if (transformations() != null) { + transformations().forEach(e -> e.validate()); + } + } +} diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/MappingDataFlowTypeProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/MappingDataFlowTypeProperties.java index 555f061d9142..85fb658d581f 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/MappingDataFlowTypeProperties.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/MappingDataFlowTypeProperties.java @@ -42,6 +42,12 @@ public final class MappingDataFlowTypeProperties { @JsonProperty(value = "script") private String script; + /* + * Data flow script lines. + */ + @JsonProperty(value = "scriptLines") + private List scriptLines; + /** * Get the sources property: List of sources in data flow. * @@ -122,6 +128,26 @@ public MappingDataFlowTypeProperties withScript(String script) { return this; } + /** + * Get the scriptLines property: Data flow script lines. + * + * @return the scriptLines value. + */ + public List scriptLines() { + return this.scriptLines; + } + + /** + * Set the scriptLines property: Data flow script lines. + * + * @param scriptLines the scriptLines value to set. + * @return the MappingDataFlowTypeProperties object itself. + */ + public MappingDataFlowTypeProperties withScriptLines(List scriptLines) { + this.scriptLines = scriptLines; + return this; + } + /** * Validates the instance. * diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/PipelineRunInner.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/PipelineRunInner.java index 07bfa3bbec33..d12dc3cc4677 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/PipelineRunInner.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/PipelineRunInner.java @@ -91,7 +91,8 @@ public final class PipelineRunInner { private Integer durationInMs; /* - * The status of a pipeline run. + * The status of a pipeline run. Possible values: Queued, InProgress, + * Succeeded, Failed, Canceling, Cancelled */ @JsonProperty(value = "status", access = JsonProperty.Access.WRITE_ONLY) private String status; @@ -207,7 +208,8 @@ public Integer durationInMs() { } /** - * Get the status property: The status of a pipeline run. + * Get the status property: The status of a pipeline run. Possible values: Queued, InProgress, Succeeded, Failed, + * Canceling, Cancelled. * * @return the status value. */ diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/PowerQueryTypeProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/PowerQueryTypeProperties.java index 4e6395a81700..6f124d5aaf58 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/PowerQueryTypeProperties.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/PowerQueryTypeProperties.java @@ -28,6 +28,12 @@ public final class PowerQueryTypeProperties { @JsonProperty(value = "script") private String script; + /* + * Locale of the Power query mashup document. + */ + @JsonProperty(value = "documentLocale") + private String documentLocale; + /** * Get the sources property: List of sources in Power Query. * @@ -68,6 +74,26 @@ public PowerQueryTypeProperties withScript(String script) { return this; } + /** + * Get the documentLocale property: Locale of the Power query mashup document. + * + * @return the documentLocale value. + */ + public String documentLocale() { + return this.documentLocale; + } + + /** + * Set the documentLocale property: Locale of the Power query mashup document. + * + * @param documentLocale the documentLocale value to set. + * @return the PowerQueryTypeProperties object itself. + */ + public PowerQueryTypeProperties withDocumentLocale(String documentLocale) { + this.documentLocale = documentLocale; + return this; + } + /** * Validates the instance. * diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFlowDebugSessionsClientImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFlowDebugSessionsClientImpl.java index 45da2af83323..c72c383db0ac 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFlowDebugSessionsClientImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFlowDebugSessionsClientImpl.java @@ -283,7 +283,7 @@ private Mono>> createWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure for creating data flow debug session. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, CreateDataFlowDebugSessionResponseInner> beginCreateAsync(String resourceGroupName, String factoryName, CreateDataFlowDebugSessionRequest request) { Mono>> mono = createWithResponseAsync(resourceGroupName, factoryName, request); @@ -309,7 +309,7 @@ private Mono>> createWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure for creating data flow debug session. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, CreateDataFlowDebugSessionResponseInner> beginCreateAsync( String resourceGroupName, String factoryName, CreateDataFlowDebugSessionRequest request, Context context) { @@ -337,7 +337,7 @@ private Mono>> createWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure for creating data flow debug session. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, CreateDataFlowDebugSessionResponseInner> beginCreate(String resourceGroupName, String factoryName, CreateDataFlowDebugSessionRequest request) { return beginCreateAsync(resourceGroupName, factoryName, request).getSyncPoller(); @@ -355,7 +355,7 @@ private Mono>> createWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure for creating data flow debug session. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, CreateDataFlowDebugSessionResponseInner> beginCreate( String resourceGroupName, String factoryName, CreateDataFlowDebugSessionRequest request, Context context) { @@ -1062,7 +1062,7 @@ private Mono>> executeCommandWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure of data flow result for data preview, statistics or expression preview. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DataFlowDebugCommandResponseInner> beginExecuteCommandAsync(String resourceGroupName, String factoryName, DataFlowDebugCommandRequest request) { Mono>> mono = @@ -1089,7 +1089,7 @@ private Mono>> executeCommandWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure of data flow result for data preview, statistics or expression preview. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, DataFlowDebugCommandResponseInner> beginExecuteCommandAsync( String resourceGroupName, String factoryName, DataFlowDebugCommandRequest request, Context context) { @@ -1117,7 +1117,7 @@ private Mono>> executeCommandWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure of data flow result for data preview, statistics or expression preview. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DataFlowDebugCommandResponseInner> beginExecuteCommand(String resourceGroupName, String factoryName, DataFlowDebugCommandRequest request) { return beginExecuteCommandAsync(resourceGroupName, factoryName, request).getSyncPoller(); @@ -1135,7 +1135,7 @@ private Mono>> executeCommandWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return response body structure of data flow result for data preview, statistics or expression preview. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, DataFlowDebugCommandResponseInner> beginExecuteCommand( String resourceGroupName, String factoryName, DataFlowDebugCommandRequest request, Context context) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFlowsImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFlowsImpl.java index 4639af61cd37..59dcc106a7c6 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFlowsImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFlowsImpl.java @@ -151,7 +151,7 @@ public void deleteById(String id) { new IllegalArgumentException( String.format("The resource ID '%s' is not valid. Missing path segment 'dataflows'.", id))); } - this.deleteWithResponse(resourceGroupName, factoryName, dataFlowName, Context.NONE).getValue(); + this.deleteWithResponse(resourceGroupName, factoryName, dataFlowName, Context.NONE); } public Response deleteByIdWithResponse(String id, Context context) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DatasetsImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DatasetsImpl.java index 7f2e20ad8c54..dd665c8d7ebe 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DatasetsImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DatasetsImpl.java @@ -150,7 +150,7 @@ public void deleteById(String id) { new IllegalArgumentException( String.format("The resource ID '%s' is not valid. Missing path segment 'datasets'.", id))); } - this.deleteWithResponse(resourceGroupName, factoryName, datasetName, Context.NONE).getValue(); + this.deleteWithResponse(resourceGroupName, factoryName, datasetName, Context.NONE); } public Response deleteByIdWithResponse(String id, Context context) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/FactoriesImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/FactoriesImpl.java index 09010258c36c..a745d351317a 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/FactoriesImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/FactoriesImpl.java @@ -225,7 +225,7 @@ public void deleteById(String id) { new IllegalArgumentException( String.format("The resource ID '%s' is not valid. Missing path segment 'factories'.", id))); } - this.deleteWithResponse(resourceGroupName, factoryName, Context.NONE).getValue(); + this.deleteWithResponse(resourceGroupName, factoryName, Context.NONE); } public Response deleteByIdWithResponse(String id, Context context) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/FactoryImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/FactoryImpl.java index 798a92bb24ee..9256c83eaed8 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/FactoryImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/FactoryImpl.java @@ -288,8 +288,13 @@ public FactoryImpl withEncryption(EncryptionConfiguration encryption) { } public FactoryImpl withPublicNetworkAccess(PublicNetworkAccess publicNetworkAccess) { - this.innerModel().withPublicNetworkAccess(publicNetworkAccess); - return this; + if (isInCreateMode()) { + this.innerModel().withPublicNetworkAccess(publicNetworkAccess); + return this; + } else { + this.updateFactoryUpdateParameters.withPublicNetworkAccess(publicNetworkAccess); + return this; + } } public FactoryImpl withIfMatch(String ifMatch) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimeObjectMetadatasClientImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimeObjectMetadatasClientImpl.java index 4abe5cf1a4a2..bd8fd5ed5c03 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimeObjectMetadatasClientImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimeObjectMetadatasClientImpl.java @@ -221,7 +221,7 @@ private Mono>> refreshWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the status of the operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, SsisObjectMetadataStatusResponseInner> beginRefreshAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { Mono>> mono = @@ -248,7 +248,7 @@ private Mono>> refreshWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the status of the operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, SsisObjectMetadataStatusResponseInner> beginRefreshAsync( String resourceGroupName, String factoryName, String integrationRuntimeName, Context context) { @@ -276,7 +276,7 @@ private Mono>> refreshWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the status of the operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, SsisObjectMetadataStatusResponseInner> beginRefresh(String resourceGroupName, String factoryName, String integrationRuntimeName) { return beginRefreshAsync(resourceGroupName, factoryName, integrationRuntimeName).getSyncPoller(); @@ -294,7 +294,7 @@ private Mono>> refreshWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the status of the operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, SsisObjectMetadataStatusResponseInner> beginRefresh(String resourceGroupName, String factoryName, String integrationRuntimeName, Context context) { return beginRefreshAsync(resourceGroupName, factoryName, integrationRuntimeName, context).getSyncPoller(); diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimesClientImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimesClientImpl.java index 4dc6d0d9f2c4..eb03ef99ca16 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimesClientImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimesClientImpl.java @@ -2408,7 +2408,7 @@ private Mono>> startWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return integration runtime status response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, IntegrationRuntimeStatusResponseInner> beginStartAsync(String resourceGroupName, String factoryName, String integrationRuntimeName) { Mono>> mono = @@ -2435,7 +2435,7 @@ private Mono>> startWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return integration runtime status response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, IntegrationRuntimeStatusResponseInner> beginStartAsync(String resourceGroupName, String factoryName, String integrationRuntimeName, Context context) { context = this.client.mergeContext(context); @@ -2462,7 +2462,7 @@ private Mono>> startWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return integration runtime status response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, IntegrationRuntimeStatusResponseInner> beginStart(String resourceGroupName, String factoryName, String integrationRuntimeName) { return beginStartAsync(resourceGroupName, factoryName, integrationRuntimeName).getSyncPoller(); @@ -2480,7 +2480,7 @@ private Mono>> startWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return integration runtime status response. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, IntegrationRuntimeStatusResponseInner> beginStart(String resourceGroupName, String factoryName, String integrationRuntimeName, Context context) { return beginStartAsync(resourceGroupName, factoryName, integrationRuntimeName, context).getSyncPoller(); @@ -2679,7 +2679,7 @@ private Mono>> stopWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginStopAsync( String resourceGroupName, String factoryName, String integrationRuntimeName) { Mono>> mono = @@ -2701,7 +2701,7 @@ private PollerFlux, Void> beginStopAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginStopAsync( String resourceGroupName, String factoryName, String integrationRuntimeName, Context context) { context = this.client.mergeContext(context); @@ -2723,7 +2723,7 @@ private PollerFlux, Void> beginStopAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginStop( String resourceGroupName, String factoryName, String integrationRuntimeName) { return beginStopAsync(resourceGroupName, factoryName, integrationRuntimeName).getSyncPoller(); @@ -2741,7 +2741,7 @@ public SyncPoller, Void> beginStop( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginStop( String resourceGroupName, String factoryName, String integrationRuntimeName, Context context) { return beginStopAsync(resourceGroupName, factoryName, integrationRuntimeName, context).getSyncPoller(); diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimesImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimesImpl.java index 4984f66c6be7..4673378cde26 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimesImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/IntegrationRuntimesImpl.java @@ -477,7 +477,7 @@ public void deleteById(String id) { .format( "The resource ID '%s' is not valid. Missing path segment 'integrationRuntimes'.", id))); } - this.deleteWithResponse(resourceGroupName, factoryName, integrationRuntimeName, Context.NONE).getValue(); + this.deleteWithResponse(resourceGroupName, factoryName, integrationRuntimeName, Context.NONE); } public Response deleteByIdWithResponse(String id, Context context) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/LinkedServicesImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/LinkedServicesImpl.java index e98fd209bc17..ee31bbe7078f 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/LinkedServicesImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/LinkedServicesImpl.java @@ -157,7 +157,7 @@ public void deleteById(String id) { String .format("The resource ID '%s' is not valid. Missing path segment 'linkedservices'.", id))); } - this.deleteWithResponse(resourceGroupName, factoryName, linkedServiceName, Context.NONE).getValue(); + this.deleteWithResponse(resourceGroupName, factoryName, linkedServiceName, Context.NONE); } public Response deleteByIdWithResponse(String id, Context context) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/ManagedPrivateEndpointsImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/ManagedPrivateEndpointsImpl.java index 05a8cd735c97..330d9b97c310 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/ManagedPrivateEndpointsImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/ManagedPrivateEndpointsImpl.java @@ -242,8 +242,7 @@ public void deleteById(String id) { } this .deleteWithResponse( - resourceGroupName, factoryName, managedVirtualNetworkName, managedPrivateEndpointName, Context.NONE) - .getValue(); + resourceGroupName, factoryName, managedVirtualNetworkName, managedPrivateEndpointName, Context.NONE); } public Response deleteByIdWithResponse(String id, Context context) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/PipelinesImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/PipelinesImpl.java index 4500c1742acd..2df3f8543e5b 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/PipelinesImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/PipelinesImpl.java @@ -197,7 +197,7 @@ public void deleteById(String id) { new IllegalArgumentException( String.format("The resource ID '%s' is not valid. Missing path segment 'pipelines'.", id))); } - this.deleteWithResponse(resourceGroupName, factoryName, pipelineName, Context.NONE).getValue(); + this.deleteWithResponse(resourceGroupName, factoryName, pipelineName, Context.NONE); } public Response deleteByIdWithResponse(String id, Context context) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/PrivateEndpointConnectionOperationsImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/PrivateEndpointConnectionOperationsImpl.java index 02cf991fd2ca..967b45b7fbd9 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/PrivateEndpointConnectionOperationsImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/PrivateEndpointConnectionOperationsImpl.java @@ -161,7 +161,7 @@ public void deleteById(String id) { "The resource ID '%s' is not valid. Missing path segment 'privateEndpointConnections'.", id))); } - this.deleteWithResponse(resourceGroupName, factoryName, privateEndpointConnectionName, Context.NONE).getValue(); + this.deleteWithResponse(resourceGroupName, factoryName, privateEndpointConnectionName, Context.NONE); } public Response deleteByIdWithResponse(String id, Context context) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/TriggersClientImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/TriggersClientImpl.java index 878d71fb4614..2f79e170e3c3 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/TriggersClientImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/TriggersClientImpl.java @@ -1299,7 +1299,7 @@ private Mono>> subscribeToEventsWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, TriggerSubscriptionOperationStatusInner> beginSubscribeToEventsAsync(String resourceGroupName, String factoryName, String triggerName) { Mono>> mono = @@ -1326,7 +1326,7 @@ private Mono>> subscribeToEventsWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, TriggerSubscriptionOperationStatusInner> beginSubscribeToEventsAsync(String resourceGroupName, String factoryName, String triggerName, Context context) { context = this.client.mergeContext(context); @@ -1353,7 +1353,7 @@ private Mono>> subscribeToEventsWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, TriggerSubscriptionOperationStatusInner> beginSubscribeToEvents(String resourceGroupName, String factoryName, String triggerName) { return beginSubscribeToEventsAsync(resourceGroupName, factoryName, triggerName).getSyncPoller(); @@ -1371,7 +1371,7 @@ private Mono>> subscribeToEventsWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, TriggerSubscriptionOperationStatusInner> beginSubscribeToEvents(String resourceGroupName, String factoryName, String triggerName, Context context) { return beginSubscribeToEventsAsync(resourceGroupName, factoryName, triggerName, context).getSyncPoller(); @@ -1731,7 +1731,7 @@ private Mono>> unsubscribeFromEventsWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, TriggerSubscriptionOperationStatusInner> beginUnsubscribeFromEventsAsync(String resourceGroupName, String factoryName, String triggerName) { Mono>> mono = @@ -1758,7 +1758,7 @@ private Mono>> unsubscribeFromEventsWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, TriggerSubscriptionOperationStatusInner> beginUnsubscribeFromEventsAsync( String resourceGroupName, String factoryName, String triggerName, Context context) { @@ -1786,7 +1786,7 @@ private Mono>> unsubscribeFromEventsWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, TriggerSubscriptionOperationStatusInner> beginUnsubscribeFromEvents(String resourceGroupName, String factoryName, String triggerName) { return beginUnsubscribeFromEventsAsync(resourceGroupName, factoryName, triggerName).getSyncPoller(); @@ -1804,7 +1804,7 @@ private Mono>> unsubscribeFromEventsWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return defines the response of a trigger subscription operation. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, TriggerSubscriptionOperationStatusInner> beginUnsubscribeFromEvents(String resourceGroupName, String factoryName, String triggerName, Context context) { return beginUnsubscribeFromEventsAsync(resourceGroupName, factoryName, triggerName, context).getSyncPoller(); @@ -1999,7 +1999,7 @@ private Mono>> startWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginStartAsync( String resourceGroupName, String factoryName, String triggerName) { Mono>> mono = startWithResponseAsync(resourceGroupName, factoryName, triggerName); @@ -2020,7 +2020,7 @@ private PollerFlux, Void> beginStartAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginStartAsync( String resourceGroupName, String factoryName, String triggerName, Context context) { context = this.client.mergeContext(context); @@ -2042,7 +2042,7 @@ private PollerFlux, Void> beginStartAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginStart( String resourceGroupName, String factoryName, String triggerName) { return beginStartAsync(resourceGroupName, factoryName, triggerName).getSyncPoller(); @@ -2060,7 +2060,7 @@ public SyncPoller, Void> beginStart( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginStart( String resourceGroupName, String factoryName, String triggerName, Context context) { return beginStartAsync(resourceGroupName, factoryName, triggerName, context).getSyncPoller(); @@ -2249,7 +2249,7 @@ private Mono>> stopWithResponseAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginStopAsync( String resourceGroupName, String factoryName, String triggerName) { Mono>> mono = stopWithResponseAsync(resourceGroupName, factoryName, triggerName); @@ -2270,7 +2270,7 @@ private PollerFlux, Void> beginStopAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) private PollerFlux, Void> beginStopAsync( String resourceGroupName, String factoryName, String triggerName, Context context) { context = this.client.mergeContext(context); @@ -2292,7 +2292,7 @@ private PollerFlux, Void> beginStopAsync( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginStop( String resourceGroupName, String factoryName, String triggerName) { return beginStopAsync(resourceGroupName, factoryName, triggerName).getSyncPoller(); @@ -2310,7 +2310,7 @@ public SyncPoller, Void> beginStop( * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent. * @return the completion. */ - @ServiceMethod(returns = ReturnType.SINGLE) + @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION) public SyncPoller, Void> beginStop( String resourceGroupName, String factoryName, String triggerName, Context context) { return beginStopAsync(resourceGroupName, factoryName, triggerName, context).getSyncPoller(); diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/TriggersImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/TriggersImpl.java index ba8c7e3ea8e8..8b9725abb8a1 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/TriggersImpl.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/TriggersImpl.java @@ -269,7 +269,7 @@ public void deleteById(String id) { new IllegalArgumentException( String.format("The resource ID '%s' is not valid. Missing path segment 'triggers'.", id))); } - this.deleteWithResponse(resourceGroupName, factoryName, triggerName, Context.NONE).getValue(); + this.deleteWithResponse(resourceGroupName, factoryName, triggerName, Context.NONE); } public Response deleteByIdWithResponse(String id, Context context) { diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/CredentialReference.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/CredentialReference.java index aebbb2950347..9dbbdfed8186 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/CredentialReference.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/CredentialReference.java @@ -22,7 +22,7 @@ public final class CredentialReference { * Credential reference type. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "CredentialReference"; /* * Reference credential name. diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlow.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlow.java index 20ebcbeea48c..cceda40c1bf5 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlow.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlow.java @@ -22,6 +22,7 @@ @JsonTypeName("DataFlow") @JsonSubTypes({ @JsonSubTypes.Type(name = "MappingDataFlow", value = MappingDataFlow.class), + @JsonSubTypes.Type(name = "Flowlet", value = Flowlet.class), @JsonSubTypes.Type(name = "WranglingDataFlow", value = WranglingDataFlow.class) }) @Fluent diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowDebugPackage.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowDebugPackage.java index 87521ba07a1a..49aa50d5ab3b 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowDebugPackage.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowDebugPackage.java @@ -31,6 +31,12 @@ public final class DataFlowDebugPackage { @JsonProperty(value = "dataFlow") private DataFlowDebugResource dataFlow; + /* + * List of Data flows + */ + @JsonProperty(value = "dataFlows") + private List dataFlows; + /* * List of datasets. */ @@ -100,6 +106,26 @@ public DataFlowDebugPackage withDataFlow(DataFlowDebugResource dataFlow) { return this; } + /** + * Get the dataFlows property: List of Data flows. + * + * @return the dataFlows value. + */ + public List dataFlows() { + return this.dataFlows; + } + + /** + * Set the dataFlows property: List of Data flows. + * + * @param dataFlows the dataFlows value to set. + * @return the DataFlowDebugPackage object itself. + */ + public DataFlowDebugPackage withDataFlows(List dataFlows) { + this.dataFlows = dataFlows; + return this; + } + /** * Get the datasets property: List of datasets. * @@ -218,6 +244,9 @@ public void validate() { if (dataFlow() != null) { dataFlow().validate(); } + if (dataFlows() != null) { + dataFlows().forEach(e -> e.validate()); + } if (datasets() != null) { datasets().forEach(e -> e.validate()); } diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowReference.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowReference.java index 3ae0b8eaddbd..66615e0b742b 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowReference.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowReference.java @@ -22,7 +22,7 @@ public final class DataFlowReference { * Data flow reference type. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "DataFlowReference"; /* * Reference data flow name. diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowSink.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowSink.java index 8e336a3c3419..8a73b2bca27e 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowSink.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowSink.java @@ -14,64 +14,12 @@ public class DataFlowSink extends Transformation { @JsonIgnore private final ClientLogger logger = new ClientLogger(DataFlowSink.class); - /* - * Dataset reference. - */ - @JsonProperty(value = "dataset") - private DatasetReference dataset; - - /* - * Linked service reference. - */ - @JsonProperty(value = "linkedService") - private LinkedServiceReference linkedService; - /* * Schema linked service reference. */ @JsonProperty(value = "schemaLinkedService") private LinkedServiceReference schemaLinkedService; - /** - * Get the dataset property: Dataset reference. - * - * @return the dataset value. - */ - public DatasetReference dataset() { - return this.dataset; - } - - /** - * Set the dataset property: Dataset reference. - * - * @param dataset the dataset value to set. - * @return the DataFlowSink object itself. - */ - public DataFlowSink withDataset(DatasetReference dataset) { - this.dataset = dataset; - return this; - } - - /** - * Get the linkedService property: Linked service reference. - * - * @return the linkedService value. - */ - public LinkedServiceReference linkedService() { - return this.linkedService; - } - - /** - * Set the linkedService property: Linked service reference. - * - * @param linkedService the linkedService value to set. - * @return the DataFlowSink object itself. - */ - public DataFlowSink withLinkedService(LinkedServiceReference linkedService) { - this.linkedService = linkedService; - return this; - } - /** * Get the schemaLinkedService property: Schema linked service reference. * @@ -106,6 +54,27 @@ public DataFlowSink withDescription(String description) { return this; } + /** {@inheritDoc} */ + @Override + public DataFlowSink withDataset(DatasetReference dataset) { + super.withDataset(dataset); + return this; + } + + /** {@inheritDoc} */ + @Override + public DataFlowSink withLinkedService(LinkedServiceReference linkedService) { + super.withLinkedService(linkedService); + return this; + } + + /** {@inheritDoc} */ + @Override + public DataFlowSink withFlowlet(DataFlowReference flowlet) { + super.withFlowlet(flowlet); + return this; + } + /** * Validates the instance. * @@ -114,12 +83,6 @@ public DataFlowSink withDescription(String description) { @Override public void validate() { super.validate(); - if (dataset() != null) { - dataset().validate(); - } - if (linkedService() != null) { - linkedService().validate(); - } if (schemaLinkedService() != null) { schemaLinkedService().validate(); } diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowSource.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowSource.java index 14df3a146e38..975f6ec65af2 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowSource.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DataFlowSource.java @@ -14,64 +14,12 @@ public class DataFlowSource extends Transformation { @JsonIgnore private final ClientLogger logger = new ClientLogger(DataFlowSource.class); - /* - * Dataset reference. - */ - @JsonProperty(value = "dataset") - private DatasetReference dataset; - - /* - * Linked service reference. - */ - @JsonProperty(value = "linkedService") - private LinkedServiceReference linkedService; - /* * Schema linked service reference. */ @JsonProperty(value = "schemaLinkedService") private LinkedServiceReference schemaLinkedService; - /** - * Get the dataset property: Dataset reference. - * - * @return the dataset value. - */ - public DatasetReference dataset() { - return this.dataset; - } - - /** - * Set the dataset property: Dataset reference. - * - * @param dataset the dataset value to set. - * @return the DataFlowSource object itself. - */ - public DataFlowSource withDataset(DatasetReference dataset) { - this.dataset = dataset; - return this; - } - - /** - * Get the linkedService property: Linked service reference. - * - * @return the linkedService value. - */ - public LinkedServiceReference linkedService() { - return this.linkedService; - } - - /** - * Set the linkedService property: Linked service reference. - * - * @param linkedService the linkedService value to set. - * @return the DataFlowSource object itself. - */ - public DataFlowSource withLinkedService(LinkedServiceReference linkedService) { - this.linkedService = linkedService; - return this; - } - /** * Get the schemaLinkedService property: Schema linked service reference. * @@ -106,6 +54,27 @@ public DataFlowSource withDescription(String description) { return this; } + /** {@inheritDoc} */ + @Override + public DataFlowSource withDataset(DatasetReference dataset) { + super.withDataset(dataset); + return this; + } + + /** {@inheritDoc} */ + @Override + public DataFlowSource withLinkedService(LinkedServiceReference linkedService) { + super.withLinkedService(linkedService); + return this; + } + + /** {@inheritDoc} */ + @Override + public DataFlowSource withFlowlet(DataFlowReference flowlet) { + super.withFlowlet(flowlet); + return this; + } + /** * Validates the instance. * @@ -114,12 +83,6 @@ public DataFlowSource withDescription(String description) { @Override public void validate() { super.validate(); - if (dataset() != null) { - dataset().validate(); - } - if (linkedService() != null) { - linkedService().validate(); - } if (schemaLinkedService() != null) { schemaLinkedService().validate(); } diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetBZip2Compression.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetBZip2Compression.java deleted file mode 100644 index f03a2346e78c..000000000000 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetBZip2Compression.java +++ /dev/null @@ -1,29 +0,0 @@ -// Copyright (c) Microsoft Corporation. All rights reserved. -// Licensed under the MIT License. -// Code generated by Microsoft (R) AutoRest Code Generator. - -package com.azure.resourcemanager.datafactory.models; - -import com.azure.core.annotation.Immutable; -import com.azure.core.util.logging.ClientLogger; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonTypeInfo; -import com.fasterxml.jackson.annotation.JsonTypeName; - -/** The BZip2 compression method used on a dataset. */ -@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") -@JsonTypeName("BZip2") -@Immutable -public final class DatasetBZip2Compression extends DatasetCompression { - @JsonIgnore private final ClientLogger logger = new ClientLogger(DatasetBZip2Compression.class); - - /** - * Validates the instance. - * - * @throws IllegalArgumentException thrown if the instance is not valid. - */ - @Override - public void validate() { - super.validate(); - } -} diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetCompression.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetCompression.java index 551b2bdbb941..2fab3a82492c 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetCompression.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetCompression.java @@ -9,36 +9,74 @@ import com.fasterxml.jackson.annotation.JsonAnyGetter; import com.fasterxml.jackson.annotation.JsonAnySetter; import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonSubTypes; -import com.fasterxml.jackson.annotation.JsonTypeInfo; -import com.fasterxml.jackson.annotation.JsonTypeName; +import com.fasterxml.jackson.annotation.JsonProperty; import java.util.HashMap; import java.util.Map; /** The compression method used on a dataset. */ -@JsonTypeInfo( - use = JsonTypeInfo.Id.NAME, - include = JsonTypeInfo.As.PROPERTY, - property = "type", - defaultImpl = DatasetCompression.class) -@JsonTypeName("DatasetCompression") -@JsonSubTypes({ - @JsonSubTypes.Type(name = "BZip2", value = DatasetBZip2Compression.class), - @JsonSubTypes.Type(name = "GZip", value = DatasetGZipCompression.class), - @JsonSubTypes.Type(name = "Deflate", value = DatasetDeflateCompression.class), - @JsonSubTypes.Type(name = "ZipDeflate", value = DatasetZipDeflateCompression.class), - @JsonSubTypes.Type(name = "Tar", value = DatasetTarCompression.class), - @JsonSubTypes.Type(name = "TarGZip", value = DatasetTarGZipCompression.class) -}) @Fluent -public class DatasetCompression { +public final class DatasetCompression { @JsonIgnore private final ClientLogger logger = new ClientLogger(DatasetCompression.class); + /* + * Type of dataset compression. Type: string (or Expression with resultType + * string). + */ + @JsonProperty(value = "type", required = true) + private Object type; + + /* + * The dataset compression level. Type: string (or Expression with + * resultType string). + */ + @JsonProperty(value = "level") + private Object level; + /* * The compression method used on a dataset. */ @JsonIgnore private Map additionalProperties; + /** + * Get the type property: Type of dataset compression. Type: string (or Expression with resultType string). + * + * @return the type value. + */ + public Object type() { + return this.type; + } + + /** + * Set the type property: Type of dataset compression. Type: string (or Expression with resultType string). + * + * @param type the type value to set. + * @return the DatasetCompression object itself. + */ + public DatasetCompression withType(Object type) { + this.type = type; + return this; + } + + /** + * Get the level property: The dataset compression level. Type: string (or Expression with resultType string). + * + * @return the level value. + */ + public Object level() { + return this.level; + } + + /** + * Set the level property: The dataset compression level. Type: string (or Expression with resultType string). + * + * @param level the level value to set. + * @return the DatasetCompression object itself. + */ + public DatasetCompression withLevel(Object level) { + this.level = level; + return this; + } + /** * Get the additionalProperties property: The compression method used on a dataset. * @@ -74,5 +112,10 @@ void withAdditionalProperties(String key, Object value) { * @throws IllegalArgumentException thrown if the instance is not valid. */ public void validate() { + if (type() == null) { + throw logger + .logExceptionAsError( + new IllegalArgumentException("Missing required property type in model DatasetCompression")); + } } } diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetDeflateCompression.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetDeflateCompression.java deleted file mode 100644 index 195ce6f69c51..000000000000 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetDeflateCompression.java +++ /dev/null @@ -1,56 +0,0 @@ -// Copyright (c) Microsoft Corporation. All rights reserved. -// Licensed under the MIT License. -// Code generated by Microsoft (R) AutoRest Code Generator. - -package com.azure.resourcemanager.datafactory.models; - -import com.azure.core.annotation.Fluent; -import com.azure.core.util.logging.ClientLogger; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonTypeInfo; -import com.fasterxml.jackson.annotation.JsonTypeName; - -/** The Deflate compression method used on a dataset. */ -@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") -@JsonTypeName("Deflate") -@Fluent -public final class DatasetDeflateCompression extends DatasetCompression { - @JsonIgnore private final ClientLogger logger = new ClientLogger(DatasetDeflateCompression.class); - - /* - * The Deflate compression level. - */ - @JsonProperty(value = "level") - private Object level; - - /** - * Get the level property: The Deflate compression level. - * - * @return the level value. - */ - public Object level() { - return this.level; - } - - /** - * Set the level property: The Deflate compression level. - * - * @param level the level value to set. - * @return the DatasetDeflateCompression object itself. - */ - public DatasetDeflateCompression withLevel(Object level) { - this.level = level; - return this; - } - - /** - * Validates the instance. - * - * @throws IllegalArgumentException thrown if the instance is not valid. - */ - @Override - public void validate() { - super.validate(); - } -} diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetGZipCompression.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetGZipCompression.java deleted file mode 100644 index d009549fc9bc..000000000000 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetGZipCompression.java +++ /dev/null @@ -1,56 +0,0 @@ -// Copyright (c) Microsoft Corporation. All rights reserved. -// Licensed under the MIT License. -// Code generated by Microsoft (R) AutoRest Code Generator. - -package com.azure.resourcemanager.datafactory.models; - -import com.azure.core.annotation.Fluent; -import com.azure.core.util.logging.ClientLogger; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonTypeInfo; -import com.fasterxml.jackson.annotation.JsonTypeName; - -/** The GZip compression method used on a dataset. */ -@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") -@JsonTypeName("GZip") -@Fluent -public final class DatasetGZipCompression extends DatasetCompression { - @JsonIgnore private final ClientLogger logger = new ClientLogger(DatasetGZipCompression.class); - - /* - * The GZip compression level. - */ - @JsonProperty(value = "level") - private Object level; - - /** - * Get the level property: The GZip compression level. - * - * @return the level value. - */ - public Object level() { - return this.level; - } - - /** - * Set the level property: The GZip compression level. - * - * @param level the level value to set. - * @return the DatasetGZipCompression object itself. - */ - public DatasetGZipCompression withLevel(Object level) { - this.level = level; - return this; - } - - /** - * Validates the instance. - * - * @throws IllegalArgumentException thrown if the instance is not valid. - */ - @Override - public void validate() { - super.validate(); - } -} diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetReference.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetReference.java index eb32474a589a..6e51f831d803 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetReference.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetReference.java @@ -20,7 +20,7 @@ public final class DatasetReference { * Dataset reference type. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "DatasetReference"; /* * Reference dataset name. diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetTarCompression.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetTarCompression.java deleted file mode 100644 index 183661172874..000000000000 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetTarCompression.java +++ /dev/null @@ -1,29 +0,0 @@ -// Copyright (c) Microsoft Corporation. All rights reserved. -// Licensed under the MIT License. -// Code generated by Microsoft (R) AutoRest Code Generator. - -package com.azure.resourcemanager.datafactory.models; - -import com.azure.core.annotation.Immutable; -import com.azure.core.util.logging.ClientLogger; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonTypeInfo; -import com.fasterxml.jackson.annotation.JsonTypeName; - -/** The Tar archive method used on a dataset. */ -@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") -@JsonTypeName("Tar") -@Immutable -public final class DatasetTarCompression extends DatasetCompression { - @JsonIgnore private final ClientLogger logger = new ClientLogger(DatasetTarCompression.class); - - /** - * Validates the instance. - * - * @throws IllegalArgumentException thrown if the instance is not valid. - */ - @Override - public void validate() { - super.validate(); - } -} diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetTarGZipCompression.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetTarGZipCompression.java deleted file mode 100644 index 18531ac560c7..000000000000 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetTarGZipCompression.java +++ /dev/null @@ -1,56 +0,0 @@ -// Copyright (c) Microsoft Corporation. All rights reserved. -// Licensed under the MIT License. -// Code generated by Microsoft (R) AutoRest Code Generator. - -package com.azure.resourcemanager.datafactory.models; - -import com.azure.core.annotation.Fluent; -import com.azure.core.util.logging.ClientLogger; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonTypeInfo; -import com.fasterxml.jackson.annotation.JsonTypeName; - -/** The TarGZip compression method used on a dataset. */ -@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") -@JsonTypeName("TarGZip") -@Fluent -public final class DatasetTarGZipCompression extends DatasetCompression { - @JsonIgnore private final ClientLogger logger = new ClientLogger(DatasetTarGZipCompression.class); - - /* - * The TarGZip compression level. - */ - @JsonProperty(value = "level") - private Object level; - - /** - * Get the level property: The TarGZip compression level. - * - * @return the level value. - */ - public Object level() { - return this.level; - } - - /** - * Set the level property: The TarGZip compression level. - * - * @param level the level value to set. - * @return the DatasetTarGZipCompression object itself. - */ - public DatasetTarGZipCompression withLevel(Object level) { - this.level = level; - return this; - } - - /** - * Validates the instance. - * - * @throws IllegalArgumentException thrown if the instance is not valid. - */ - @Override - public void validate() { - super.validate(); - } -} diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetZipDeflateCompression.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetZipDeflateCompression.java deleted file mode 100644 index 715264afb80b..000000000000 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DatasetZipDeflateCompression.java +++ /dev/null @@ -1,56 +0,0 @@ -// Copyright (c) Microsoft Corporation. All rights reserved. -// Licensed under the MIT License. -// Code generated by Microsoft (R) AutoRest Code Generator. - -package com.azure.resourcemanager.datafactory.models; - -import com.azure.core.annotation.Fluent; -import com.azure.core.util.logging.ClientLogger; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonTypeInfo; -import com.fasterxml.jackson.annotation.JsonTypeName; - -/** The ZipDeflate compression method used on a dataset. */ -@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") -@JsonTypeName("ZipDeflate") -@Fluent -public final class DatasetZipDeflateCompression extends DatasetCompression { - @JsonIgnore private final ClientLogger logger = new ClientLogger(DatasetZipDeflateCompression.class); - - /* - * The ZipDeflate compression level. - */ - @JsonProperty(value = "level") - private Object level; - - /** - * Get the level property: The ZipDeflate compression level. - * - * @return the level value. - */ - public Object level() { - return this.level; - } - - /** - * Set the level property: The ZipDeflate compression level. - * - * @param level the level value to set. - * @return the DatasetZipDeflateCompression object itself. - */ - public DatasetZipDeflateCompression withLevel(Object level) { - this.level = level; - return this; - } - - /** - * Validates the instance. - * - * @throws IllegalArgumentException thrown if the instance is not valid. - */ - @Override - public void validate() { - super.validate(); - } -} diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ExecuteWranglingDataflowActivity.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ExecuteWranglingDataflowActivity.java index 07388f1832da..dac8014a64e8 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ExecuteWranglingDataflowActivity.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ExecuteWranglingDataflowActivity.java @@ -91,7 +91,8 @@ public ExecuteWranglingDataflowActivity withUserProperties(List us } /** - * Get the sinks property: List of Power Query activity sinks mapped to a queryName. + * Get the sinks property: (Deprecated. Please use Queries). List of Power Query activity sinks mapped to a + * queryName. * * @return the sinks value. */ @@ -100,7 +101,8 @@ public Map sinks() { } /** - * Set the sinks property: List of Power Query activity sinks mapped to a queryName. + * Set the sinks property: (Deprecated. Please use Queries). List of Power Query activity sinks mapped to a + * queryName. * * @param sinks the sinks value to set. * @return the ExecuteWranglingDataflowActivity object itself. @@ -113,6 +115,29 @@ public ExecuteWranglingDataflowActivity withSinks(Map si return this; } + /** + * Get the queries property: List of mapping for Power Query mashup query to sink dataset(s). + * + * @return the queries value. + */ + public List queries() { + return this.innerTypeProperties() == null ? null : this.innerTypeProperties().queries(); + } + + /** + * Set the queries property: List of mapping for Power Query mashup query to sink dataset(s). + * + * @param queries the queries value to set. + * @return the ExecuteWranglingDataflowActivity object itself. + */ + public ExecuteWranglingDataflowActivity withQueries(List queries) { + if (this.innerTypeProperties() == null) { + this.innerTypeProperties = new ExecutePowerQueryActivityTypeProperties(); + } + this.innerTypeProperties().withQueries(queries); + return this; + } + /** * Get the dataFlow property: Data flow reference. * diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Expression.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Expression.java index 3dfad37c19b2..9a1800dfa309 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Expression.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Expression.java @@ -18,7 +18,7 @@ public final class Expression { * Expression type. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "Expression"; /* * Expression value. diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Factory.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Factory.java index c0ea926d45ea..5f667d11ee8e 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Factory.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Factory.java @@ -299,7 +299,7 @@ interface WithIfMatch { Factory.Update update(); /** The template for Factory update. */ - interface Update extends UpdateStages.WithTags, UpdateStages.WithIdentity { + interface Update extends UpdateStages.WithTags, UpdateStages.WithIdentity, UpdateStages.WithPublicNetworkAccess { /** * Executes the update request. * @@ -337,6 +337,17 @@ interface WithIdentity { */ Update withIdentity(FactoryIdentity identity); } + /** The stage of the Factory update allowing to specify publicNetworkAccess. */ + interface WithPublicNetworkAccess { + /** + * Specifies the publicNetworkAccess property: Whether or not public network access is allowed for the data + * factory.. + * + * @param publicNetworkAccess Whether or not public network access is allowed for the data factory. + * @return the next definition stage. + */ + Update withPublicNetworkAccess(PublicNetworkAccess publicNetworkAccess); + } } /** * Refreshes the resource to sync with Azure. diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/FactoryUpdateParameters.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/FactoryUpdateParameters.java index 472ea3c0b550..ee779d40c7d5 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/FactoryUpdateParameters.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/FactoryUpdateParameters.java @@ -29,6 +29,12 @@ public final class FactoryUpdateParameters { @JsonProperty(value = "identity") private FactoryIdentity identity; + /* + * Whether or not public network access is allowed for the data factory. + */ + @JsonProperty(value = "publicNetworkAccess") + private PublicNetworkAccess publicNetworkAccess; + /** * Get the tags property: The resource tags. * @@ -69,6 +75,26 @@ public FactoryUpdateParameters withIdentity(FactoryIdentity identity) { return this; } + /** + * Get the publicNetworkAccess property: Whether or not public network access is allowed for the data factory. + * + * @return the publicNetworkAccess value. + */ + public PublicNetworkAccess publicNetworkAccess() { + return this.publicNetworkAccess; + } + + /** + * Set the publicNetworkAccess property: Whether or not public network access is allowed for the data factory. + * + * @param publicNetworkAccess the publicNetworkAccess value to set. + * @return the FactoryUpdateParameters object itself. + */ + public FactoryUpdateParameters withPublicNetworkAccess(PublicNetworkAccess publicNetworkAccess) { + this.publicNetworkAccess = publicNetworkAccess; + return this; + } + /** * Validates the instance. * diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Flowlet.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Flowlet.java new file mode 100644 index 000000000000..1788f38430ea --- /dev/null +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Flowlet.java @@ -0,0 +1,247 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. +// Code generated by Microsoft (R) AutoRest Code Generator. + +package com.azure.resourcemanager.datafactory.models; + +import com.azure.core.annotation.Fluent; +import com.azure.core.util.logging.ClientLogger; +import com.azure.resourcemanager.datafactory.fluent.models.FlowletTypeProperties; +import com.fasterxml.jackson.annotation.JsonAnyGetter; +import com.fasterxml.jackson.annotation.JsonAnySetter; +import com.fasterxml.jackson.annotation.JsonIgnore; +import com.fasterxml.jackson.annotation.JsonProperty; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import com.fasterxml.jackson.annotation.JsonTypeName; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** Data flow flowlet. */ +@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type") +@JsonTypeName("Flowlet") +@Fluent +public final class Flowlet extends DataFlow { + @JsonIgnore private final ClientLogger logger = new ClientLogger(Flowlet.class); + + /* + * Flowlet type properties. + */ + @JsonProperty(value = "typeProperties") + private FlowletTypeProperties innerTypeProperties; + + /* + * Data flow flowlet + */ + @JsonIgnore private Map additionalProperties; + + /** + * Get the innerTypeProperties property: Flowlet type properties. + * + * @return the innerTypeProperties value. + */ + private FlowletTypeProperties innerTypeProperties() { + return this.innerTypeProperties; + } + + /** + * Get the additionalProperties property: Data flow flowlet. + * + * @return the additionalProperties value. + */ + @JsonAnyGetter + public Map additionalProperties() { + return this.additionalProperties; + } + + /** + * Set the additionalProperties property: Data flow flowlet. + * + * @param additionalProperties the additionalProperties value to set. + * @return the Flowlet object itself. + */ + public Flowlet withAdditionalProperties(Map additionalProperties) { + this.additionalProperties = additionalProperties; + return this; + } + + @JsonAnySetter + void withAdditionalProperties(String key, Object value) { + if (additionalProperties == null) { + additionalProperties = new HashMap<>(); + } + additionalProperties.put(key, value); + } + + /** {@inheritDoc} */ + @Override + public Flowlet withDescription(String description) { + super.withDescription(description); + return this; + } + + /** {@inheritDoc} */ + @Override + public Flowlet withAnnotations(List annotations) { + super.withAnnotations(annotations); + return this; + } + + /** {@inheritDoc} */ + @Override + public Flowlet withFolder(DataFlowFolder folder) { + super.withFolder(folder); + return this; + } + + /** + * Get the sources property: List of sources in Flowlet. + * + * @return the sources value. + */ + public List sources() { + return this.innerTypeProperties() == null ? null : this.innerTypeProperties().sources(); + } + + /** + * Set the sources property: List of sources in Flowlet. + * + * @param sources the sources value to set. + * @return the Flowlet object itself. + */ + public Flowlet withSources(List sources) { + if (this.innerTypeProperties() == null) { + this.innerTypeProperties = new FlowletTypeProperties(); + } + this.innerTypeProperties().withSources(sources); + return this; + } + + /** + * Get the sinks property: List of sinks in Flowlet. + * + * @return the sinks value. + */ + public List sinks() { + return this.innerTypeProperties() == null ? null : this.innerTypeProperties().sinks(); + } + + /** + * Set the sinks property: List of sinks in Flowlet. + * + * @param sinks the sinks value to set. + * @return the Flowlet object itself. + */ + public Flowlet withSinks(List sinks) { + if (this.innerTypeProperties() == null) { + this.innerTypeProperties = new FlowletTypeProperties(); + } + this.innerTypeProperties().withSinks(sinks); + return this; + } + + /** + * Get the transformations property: List of transformations in Flowlet. + * + * @return the transformations value. + */ + public List transformations() { + return this.innerTypeProperties() == null ? null : this.innerTypeProperties().transformations(); + } + + /** + * Set the transformations property: List of transformations in Flowlet. + * + * @param transformations the transformations value to set. + * @return the Flowlet object itself. + */ + public Flowlet withTransformations(List transformations) { + if (this.innerTypeProperties() == null) { + this.innerTypeProperties = new FlowletTypeProperties(); + } + this.innerTypeProperties().withTransformations(transformations); + return this; + } + + /** + * Get the script property: Flowlet script. + * + * @return the script value. + */ + public String script() { + return this.innerTypeProperties() == null ? null : this.innerTypeProperties().script(); + } + + /** + * Set the script property: Flowlet script. + * + * @param script the script value to set. + * @return the Flowlet object itself. + */ + public Flowlet withScript(String script) { + if (this.innerTypeProperties() == null) { + this.innerTypeProperties = new FlowletTypeProperties(); + } + this.innerTypeProperties().withScript(script); + return this; + } + + /** + * Get the scriptLines property: Flowlet script lines. + * + * @return the scriptLines value. + */ + public List scriptLines() { + return this.innerTypeProperties() == null ? null : this.innerTypeProperties().scriptLines(); + } + + /** + * Set the scriptLines property: Flowlet script lines. + * + * @param scriptLines the scriptLines value to set. + * @return the Flowlet object itself. + */ + public Flowlet withScriptLines(List scriptLines) { + if (this.innerTypeProperties() == null) { + this.innerTypeProperties = new FlowletTypeProperties(); + } + this.innerTypeProperties().withScriptLines(scriptLines); + return this; + } + + /** + * Get the additionalProperties property: Any object. + * + * @return the additionalProperties value. + */ + public Object additionalProperties() { + return this.innerTypeProperties() == null ? null : this.innerTypeProperties().additionalProperties(); + } + + /** + * Set the additionalProperties property: Any object. + * + * @param additionalProperties the additionalProperties value to set. + * @return the Flowlet object itself. + */ + public Flowlet withAdditionalProperties(Object additionalProperties) { + if (this.innerTypeProperties() == null) { + this.innerTypeProperties = new FlowletTypeProperties(); + } + this.innerTypeProperties().withAdditionalProperties(additionalProperties); + return this; + } + + /** + * Validates the instance. + * + * @throws IllegalArgumentException thrown if the instance is not valid. + */ + @Override + public void validate() { + super.validate(); + if (innerTypeProperties() != null) { + innerTypeProperties().validate(); + } + } +} diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/IntegrationRuntimeReference.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/IntegrationRuntimeReference.java index 628ccd6ef32a..22ab4ac1a791 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/IntegrationRuntimeReference.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/IntegrationRuntimeReference.java @@ -20,7 +20,7 @@ public final class IntegrationRuntimeReference { * Type of integration runtime. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "IntegrationRuntimeReference"; /* * Reference integration runtime name. diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/LinkedServiceReference.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/LinkedServiceReference.java index f99065a2ff10..1d86bed5ca0c 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/LinkedServiceReference.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/LinkedServiceReference.java @@ -20,7 +20,7 @@ public final class LinkedServiceReference { * Linked service reference type. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "LinkedServiceReference"; /* * Reference LinkedService name. diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ManagedVirtualNetworkReference.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ManagedVirtualNetworkReference.java index 9cb4800a530e..b67d5cad78f9 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ManagedVirtualNetworkReference.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ManagedVirtualNetworkReference.java @@ -18,7 +18,7 @@ public final class ManagedVirtualNetworkReference { * Managed Virtual Network reference type. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "ManagedVirtualNetworkReference"; /* * Reference ManagedVirtualNetwork name. diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/MappingDataFlow.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/MappingDataFlow.java index 53155650766c..02dbf3038e53 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/MappingDataFlow.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/MappingDataFlow.java @@ -148,6 +148,29 @@ public MappingDataFlow withScript(String script) { return this; } + /** + * Get the scriptLines property: Data flow script lines. + * + * @return the scriptLines value. + */ + public List scriptLines() { + return this.innerTypeProperties() == null ? null : this.innerTypeProperties().scriptLines(); + } + + /** + * Set the scriptLines property: Data flow script lines. + * + * @param scriptLines the scriptLines value to set. + * @return the MappingDataFlow object itself. + */ + public MappingDataFlow withScriptLines(List scriptLines) { + if (this.innerTypeProperties() == null) { + this.innerTypeProperties = new MappingDataFlowTypeProperties(); + } + this.innerTypeProperties().withScriptLines(scriptLines); + return this; + } + /** * Validates the instance. * diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PipelineReference.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PipelineReference.java index 956281d038d2..d63b5a1f5094 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PipelineReference.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PipelineReference.java @@ -18,7 +18,7 @@ public final class PipelineReference { * Pipeline reference type. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "PipelineReference"; /* * Reference pipeline name. diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PipelineRun.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PipelineRun.java index 5455babc640c..b46c988a3088 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PipelineRun.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PipelineRun.java @@ -88,7 +88,8 @@ public interface PipelineRun { Integer durationInMs(); /** - * Gets the status property: The status of a pipeline run. + * Gets the status property: The status of a pipeline run. Possible values: Queued, InProgress, Succeeded, Failed, + * Canceling, Cancelled. * * @return the status value. */ diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySink.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySink.java index 1222813a1767..25b01d6f4efd 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySink.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySink.java @@ -42,36 +42,43 @@ public PowerQuerySink withScript(String script) { /** {@inheritDoc} */ @Override - public PowerQuerySink withDataset(DatasetReference dataset) { - super.withDataset(dataset); + public PowerQuerySink withSchemaLinkedService(LinkedServiceReference schemaLinkedService) { + super.withSchemaLinkedService(schemaLinkedService); return this; } /** {@inheritDoc} */ @Override - public PowerQuerySink withLinkedService(LinkedServiceReference linkedService) { - super.withLinkedService(linkedService); + public PowerQuerySink withName(String name) { + super.withName(name); return this; } /** {@inheritDoc} */ @Override - public PowerQuerySink withSchemaLinkedService(LinkedServiceReference schemaLinkedService) { - super.withSchemaLinkedService(schemaLinkedService); + public PowerQuerySink withDescription(String description) { + super.withDescription(description); return this; } /** {@inheritDoc} */ @Override - public PowerQuerySink withName(String name) { - super.withName(name); + public PowerQuerySink withDataset(DatasetReference dataset) { + super.withDataset(dataset); return this; } /** {@inheritDoc} */ @Override - public PowerQuerySink withDescription(String description) { - super.withDescription(description); + public PowerQuerySink withLinkedService(LinkedServiceReference linkedService) { + super.withLinkedService(linkedService); + return this; + } + + /** {@inheritDoc} */ + @Override + public PowerQuerySink withFlowlet(DataFlowReference flowlet) { + super.withFlowlet(flowlet); return this; } diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySinkMapping.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySinkMapping.java new file mode 100644 index 000000000000..f89fac55171b --- /dev/null +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySinkMapping.java @@ -0,0 +1,80 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. +// Code generated by Microsoft (R) AutoRest Code Generator. + +package com.azure.resourcemanager.datafactory.models; + +import com.azure.core.annotation.Fluent; +import com.azure.core.util.logging.ClientLogger; +import com.fasterxml.jackson.annotation.JsonIgnore; +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.List; + +/** Map Power Query mashup query to sink dataset(s). */ +@Fluent +public final class PowerQuerySinkMapping { + @JsonIgnore private final ClientLogger logger = new ClientLogger(PowerQuerySinkMapping.class); + + /* + * Name of the query in Power Query mashup document. + */ + @JsonProperty(value = "queryName") + private String queryName; + + /* + * List of sinks mapped to Power Query mashup query. + */ + @JsonProperty(value = "dataflowSinks") + private List dataflowSinks; + + /** + * Get the queryName property: Name of the query in Power Query mashup document. + * + * @return the queryName value. + */ + public String queryName() { + return this.queryName; + } + + /** + * Set the queryName property: Name of the query in Power Query mashup document. + * + * @param queryName the queryName value to set. + * @return the PowerQuerySinkMapping object itself. + */ + public PowerQuerySinkMapping withQueryName(String queryName) { + this.queryName = queryName; + return this; + } + + /** + * Get the dataflowSinks property: List of sinks mapped to Power Query mashup query. + * + * @return the dataflowSinks value. + */ + public List dataflowSinks() { + return this.dataflowSinks; + } + + /** + * Set the dataflowSinks property: List of sinks mapped to Power Query mashup query. + * + * @param dataflowSinks the dataflowSinks value to set. + * @return the PowerQuerySinkMapping object itself. + */ + public PowerQuerySinkMapping withDataflowSinks(List dataflowSinks) { + this.dataflowSinks = dataflowSinks; + return this; + } + + /** + * Validates the instance. + * + * @throws IllegalArgumentException thrown if the instance is not valid. + */ + public void validate() { + if (dataflowSinks() != null) { + dataflowSinks().forEach(e -> e.validate()); + } + } +} diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySource.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySource.java index ab9c1ffe9242..0085cc7b36c5 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySource.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/PowerQuerySource.java @@ -42,36 +42,43 @@ public PowerQuerySource withScript(String script) { /** {@inheritDoc} */ @Override - public PowerQuerySource withDataset(DatasetReference dataset) { - super.withDataset(dataset); + public PowerQuerySource withSchemaLinkedService(LinkedServiceReference schemaLinkedService) { + super.withSchemaLinkedService(schemaLinkedService); return this; } /** {@inheritDoc} */ @Override - public PowerQuerySource withLinkedService(LinkedServiceReference linkedService) { - super.withLinkedService(linkedService); + public PowerQuerySource withName(String name) { + super.withName(name); return this; } /** {@inheritDoc} */ @Override - public PowerQuerySource withSchemaLinkedService(LinkedServiceReference schemaLinkedService) { - super.withSchemaLinkedService(schemaLinkedService); + public PowerQuerySource withDescription(String description) { + super.withDescription(description); return this; } /** {@inheritDoc} */ @Override - public PowerQuerySource withName(String name) { - super.withName(name); + public PowerQuerySource withDataset(DatasetReference dataset) { + super.withDataset(dataset); return this; } /** {@inheritDoc} */ @Override - public PowerQuerySource withDescription(String description) { - super.withDescription(description); + public PowerQuerySource withLinkedService(LinkedServiceReference linkedService) { + super.withLinkedService(linkedService); + return this; + } + + /** {@inheritDoc} */ + @Override + public PowerQuerySource withFlowlet(DataFlowReference flowlet) { + super.withFlowlet(flowlet); return this; } diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Transformation.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Transformation.java index 3ac305a07132..e1a5c74c63c2 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Transformation.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/Transformation.java @@ -26,6 +26,24 @@ public class Transformation { @JsonProperty(value = "description") private String description; + /* + * Dataset reference. + */ + @JsonProperty(value = "dataset") + private DatasetReference dataset; + + /* + * Linked service reference. + */ + @JsonProperty(value = "linkedService") + private LinkedServiceReference linkedService; + + /* + * Flowlet Reference + */ + @JsonProperty(value = "flowlet") + private DataFlowReference flowlet; + /** * Get the name property: Transformation name. * @@ -66,6 +84,66 @@ public Transformation withDescription(String description) { return this; } + /** + * Get the dataset property: Dataset reference. + * + * @return the dataset value. + */ + public DatasetReference dataset() { + return this.dataset; + } + + /** + * Set the dataset property: Dataset reference. + * + * @param dataset the dataset value to set. + * @return the Transformation object itself. + */ + public Transformation withDataset(DatasetReference dataset) { + this.dataset = dataset; + return this; + } + + /** + * Get the linkedService property: Linked service reference. + * + * @return the linkedService value. + */ + public LinkedServiceReference linkedService() { + return this.linkedService; + } + + /** + * Set the linkedService property: Linked service reference. + * + * @param linkedService the linkedService value to set. + * @return the Transformation object itself. + */ + public Transformation withLinkedService(LinkedServiceReference linkedService) { + this.linkedService = linkedService; + return this; + } + + /** + * Get the flowlet property: Flowlet Reference. + * + * @return the flowlet value. + */ + public DataFlowReference flowlet() { + return this.flowlet; + } + + /** + * Set the flowlet property: Flowlet Reference. + * + * @param flowlet the flowlet value to set. + * @return the Transformation object itself. + */ + public Transformation withFlowlet(DataFlowReference flowlet) { + this.flowlet = flowlet; + return this; + } + /** * Validates the instance. * @@ -77,5 +155,14 @@ public void validate() { .logExceptionAsError( new IllegalArgumentException("Missing required property name in model Transformation")); } + if (dataset() != null) { + dataset().validate(); + } + if (linkedService() != null) { + linkedService().validate(); + } + if (flowlet() != null) { + flowlet().validate(); + } } } diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/TriggerReference.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/TriggerReference.java index bd0755318af8..cc5ffc84f811 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/TriggerReference.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/TriggerReference.java @@ -18,7 +18,7 @@ public final class TriggerReference { * Trigger reference type. */ @JsonProperty(value = "type", required = true) - private String type; + private String type = "TriggerReference"; /* * Reference trigger name. diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/WranglingDataFlow.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/WranglingDataFlow.java index 30dcee255291..dedb28b4cc04 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/WranglingDataFlow.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/WranglingDataFlow.java @@ -102,6 +102,29 @@ public WranglingDataFlow withScript(String script) { return this; } + /** + * Get the documentLocale property: Locale of the Power query mashup document. + * + * @return the documentLocale value. + */ + public String documentLocale() { + return this.innerTypeProperties() == null ? null : this.innerTypeProperties().documentLocale(); + } + + /** + * Set the documentLocale property: Locale of the Power query mashup document. + * + * @param documentLocale the documentLocale value to set. + * @return the WranglingDataFlow object itself. + */ + public WranglingDataFlow withDocumentLocale(String documentLocale) { + if (this.innerTypeProperties() == null) { + this.innerTypeProperties = new PowerQueryTypeProperties(); + } + this.innerTypeProperties().withDocumentLocale(documentLocale); + return this; + } + /** * Validates the instance. * diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/samples/java/com/azure/resourcemanager/datafactory/generated/DataFlowsCreateOrUpdateSamples.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/samples/java/com/azure/resourcemanager/datafactory/generated/DataFlowsCreateOrUpdateSamples.java index 8724324fd9f8..0164e1e84eaf 100644 --- a/sdk/datafactory/azure-resourcemanager-datafactory/src/samples/java/com/azure/resourcemanager/datafactory/generated/DataFlowsCreateOrUpdateSamples.java +++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/samples/java/com/azure/resourcemanager/datafactory/generated/DataFlowsCreateOrUpdateSamples.java @@ -58,8 +58,7 @@ public static void dataFlowsCreate(com.azure.resourcemanager.datafactory.DataFac + " string,CurrentConversionRate as double),allowSchemaDrift: true,validateSchema: false)" + " ~> CADSource\n" + "USDCurrency, CADSource union(byName: true)~> Union\n" - + "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~>" - + " NewCurrencyColumn\n" + + "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn\n" + "NewCurrencyColumn split(Country == 'USD',Country == 'CAD',disjoint: false) ~>" + " ConditionalSplit1@(USD, CAD)\n" + "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink\n" @@ -114,8 +113,7 @@ public static void dataFlowsUpdate(com.azure.resourcemanager.datafactory.DataFac + " string,CurrentConversionRate as double),allowSchemaDrift: true,validateSchema: false)" + " ~> CADSource\n" + "USDCurrency, CADSource union(byName: true)~> Union\n" - + "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~>" - + " NewCurrencyColumn\n" + + "Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~> NewCurrencyColumn\n" + "NewCurrencyColumn split(Country == 'USD',Country == 'CAD',disjoint: false) ~>" + " ConditionalSplit1@(USD, CAD)\n" + "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink\n"