diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/CHANGELOG.md b/sdk/datafactory/azure-resourcemanager-datafactory/CHANGELOG.md
index f08a331dfc92..f578ac196e6c 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.16 (Unreleased)
+## 1.0.0-beta.1 (2022-05-24)
+
+- 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 bfca1f4f28b0..aed548ba7545 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.15
+ 1.0.0-beta.16
```
[//]: # ({x-version-update-end})
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md b/sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md
index 5d92fdcdd6df..9a6b106006a2 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md
@@ -45,6 +45,13 @@
- [ListByResourceGroup](#factories_listbyresourcegroup)
- [Update](#factories_update)
+## GlobalParameters
+
+- [CreateOrUpdate](#globalparameters_createorupdate)
+- [Delete](#globalparameters_delete)
+- [Get](#globalparameters_get)
+- [ListByFactory](#globalparameters_listbyfactory)
+
## IntegrationRuntimeNodes
- [Delete](#integrationruntimenodes_delete)
@@ -1191,6 +1198,119 @@ public final class FactoriesUpdateSamples {
}
```
+### GlobalParameters_CreateOrUpdate
+
+```java
+import com.azure.core.util.Context;
+import com.azure.resourcemanager.datafactory.models.GlobalParameterResource;
+import com.azure.resourcemanager.datafactory.models.GlobalParameterSpecification;
+import java.util.Map;
+
+/** Samples for GlobalParameters CreateOrUpdate. */
+public final class GlobalParametersCreateOrUpdateSamples {
+ /*
+ * x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/GlobalParameters_Create.json
+ */
+ /**
+ * Sample code: GlobalParameters_Create.
+ *
+ * @param manager Entry point to DataFactoryManager.
+ */
+ public static void globalParametersCreate(com.azure.resourcemanager.datafactory.DataFactoryManager manager) {
+ manager
+ .globalParameters()
+ .define("default")
+ .withExistingFactory("exampleResourceGroup", "exampleFactoryName")
+ .withProperties((Map) null)
+ .create();
+ }
+
+ /*
+ * x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/GlobalParameters_Update.json
+ */
+ /**
+ * Sample code: GlobalParameters_Update.
+ *
+ * @param manager Entry point to DataFactoryManager.
+ */
+ public static void globalParametersUpdate(com.azure.resourcemanager.datafactory.DataFactoryManager manager) {
+ GlobalParameterResource resource =
+ manager
+ .globalParameters()
+ .getWithResponse("exampleResourceGroup", "exampleFactoryName", "default", Context.NONE)
+ .getValue();
+ resource.update().apply();
+ }
+}
+```
+
+### GlobalParameters_Delete
+
+```java
+import com.azure.core.util.Context;
+
+/** Samples for GlobalParameters Delete. */
+public final class GlobalParametersDeleteSamples {
+ /*
+ * x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/GlobalParameters_Delete.json
+ */
+ /**
+ * Sample code: GlobalParameters_Delete.
+ *
+ * @param manager Entry point to DataFactoryManager.
+ */
+ public static void globalParametersDelete(com.azure.resourcemanager.datafactory.DataFactoryManager manager) {
+ manager
+ .globalParameters()
+ .deleteWithResponse("exampleResourceGroup", "exampleFactoryName", "default", Context.NONE);
+ }
+}
+```
+
+### GlobalParameters_Get
+
+```java
+import com.azure.core.util.Context;
+
+/** Samples for GlobalParameters Get. */
+public final class GlobalParametersGetSamples {
+ /*
+ * x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/GlobalParameters_Get.json
+ */
+ /**
+ * Sample code: GlobalParameters_Get.
+ *
+ * @param manager Entry point to DataFactoryManager.
+ */
+ public static void globalParametersGet(com.azure.resourcemanager.datafactory.DataFactoryManager manager) {
+ manager
+ .globalParameters()
+ .getWithResponse("exampleResourceGroup", "exampleFactoryName", "default", Context.NONE);
+ }
+}
+```
+
+### GlobalParameters_ListByFactory
+
+```java
+import com.azure.core.util.Context;
+
+/** Samples for GlobalParameters ListByFactory. */
+public final class GlobalParametersListByFactorySamples {
+ /*
+ * x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/GlobalParameters_ListByFactory.json
+ */
+ /**
+ * Sample code: GlobalParameters_ListByFactory.
+ *
+ * @param manager Entry point to DataFactoryManager.
+ */
+ public static void globalParametersListByFactory(com.azure.resourcemanager.datafactory.DataFactoryManager manager) {
+ manager.globalParameters().listByFactory("exampleResourceGroup", "exampleFactoryName", Context.NONE);
+ }
+}
+```
+
### IntegrationRuntimeNodes_Delete
```java
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 9bb8b0d2f960..22ca53205881 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
@@ -31,6 +31,7 @@
import com.azure.resourcemanager.datafactory.implementation.DatasetsImpl;
import com.azure.resourcemanager.datafactory.implementation.ExposureControlsImpl;
import com.azure.resourcemanager.datafactory.implementation.FactoriesImpl;
+import com.azure.resourcemanager.datafactory.implementation.GlobalParametersImpl;
import com.azure.resourcemanager.datafactory.implementation.IntegrationRuntimeNodesImpl;
import com.azure.resourcemanager.datafactory.implementation.IntegrationRuntimeObjectMetadatasImpl;
import com.azure.resourcemanager.datafactory.implementation.IntegrationRuntimesImpl;
@@ -51,6 +52,7 @@
import com.azure.resourcemanager.datafactory.models.Datasets;
import com.azure.resourcemanager.datafactory.models.ExposureControls;
import com.azure.resourcemanager.datafactory.models.Factories;
+import com.azure.resourcemanager.datafactory.models.GlobalParameters;
import com.azure.resourcemanager.datafactory.models.IntegrationRuntimeNodes;
import com.azure.resourcemanager.datafactory.models.IntegrationRuntimeObjectMetadatas;
import com.azure.resourcemanager.datafactory.models.IntegrationRuntimes;
@@ -117,6 +119,8 @@ public final class DataFactoryManager {
private PrivateLinkResources privateLinkResources;
+ private GlobalParameters globalParameters;
+
private final DataFactoryManagementClient clientObject;
private DataFactoryManager(HttpPipeline httpPipeline, AzureProfile profile, Duration defaultPollInterval) {
@@ -282,7 +286,7 @@ public DataFactoryManager authenticate(TokenCredential credential, AzureProfile
.append("-")
.append("com.azure.resourcemanager.datafactory")
.append("/")
- .append("1.0.0-beta.15");
+ .append("1.0.0-beta.1");
if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
userAgentBuilder
.append(" (")
@@ -352,7 +356,7 @@ public Operations operations() {
}
/**
- * Gets the resource collection API of Factories.
+ * Gets the resource collection API of Factories. It manages Factory.
*
* @return Resource collection API of Factories.
*/
@@ -376,7 +380,7 @@ public ExposureControls exposureControls() {
}
/**
- * Gets the resource collection API of IntegrationRuntimes.
+ * Gets the resource collection API of IntegrationRuntimes. It manages IntegrationRuntimeResource.
*
* @return Resource collection API of IntegrationRuntimes.
*/
@@ -414,7 +418,7 @@ public IntegrationRuntimeNodes integrationRuntimeNodes() {
}
/**
- * Gets the resource collection API of LinkedServices.
+ * Gets the resource collection API of LinkedServices. It manages LinkedServiceResource.
*
* @return Resource collection API of LinkedServices.
*/
@@ -426,7 +430,7 @@ public LinkedServices linkedServices() {
}
/**
- * Gets the resource collection API of Datasets.
+ * Gets the resource collection API of Datasets. It manages DatasetResource.
*
* @return Resource collection API of Datasets.
*/
@@ -438,7 +442,7 @@ public Datasets datasets() {
}
/**
- * Gets the resource collection API of Pipelines.
+ * Gets the resource collection API of Pipelines. It manages PipelineResource.
*
* @return Resource collection API of Pipelines.
*/
@@ -474,7 +478,7 @@ public ActivityRuns activityRuns() {
}
/**
- * Gets the resource collection API of Triggers.
+ * Gets the resource collection API of Triggers. It manages TriggerResource.
*
* @return Resource collection API of Triggers.
*/
@@ -498,7 +502,7 @@ public TriggerRuns triggerRuns() {
}
/**
- * Gets the resource collection API of DataFlows.
+ * Gets the resource collection API of DataFlows. It manages DataFlowResource.
*
* @return Resource collection API of DataFlows.
*/
@@ -522,7 +526,7 @@ public DataFlowDebugSessions dataFlowDebugSessions() {
}
/**
- * Gets the resource collection API of ManagedVirtualNetworks.
+ * Gets the resource collection API of ManagedVirtualNetworks. It manages ManagedVirtualNetworkResource.
*
* @return Resource collection API of ManagedVirtualNetworks.
*/
@@ -535,7 +539,7 @@ public ManagedVirtualNetworks managedVirtualNetworks() {
}
/**
- * Gets the resource collection API of ManagedPrivateEndpoints.
+ * Gets the resource collection API of ManagedPrivateEndpoints. It manages ManagedPrivateEndpointResource.
*
* @return Resource collection API of ManagedPrivateEndpoints.
*/
@@ -561,7 +565,8 @@ public PrivateEndPointConnections privateEndPointConnections() {
}
/**
- * Gets the resource collection API of PrivateEndpointConnectionOperations.
+ * Gets the resource collection API of PrivateEndpointConnectionOperations. It manages
+ * PrivateEndpointConnectionResource.
*
* @return Resource collection API of PrivateEndpointConnectionOperations.
*/
@@ -586,6 +591,18 @@ public PrivateLinkResources privateLinkResources() {
return privateLinkResources;
}
+ /**
+ * Gets the resource collection API of GlobalParameters. It manages GlobalParameterResource.
+ *
+ * @return Resource collection API of GlobalParameters.
+ */
+ public GlobalParameters globalParameters() {
+ if (this.globalParameters == null) {
+ this.globalParameters = new GlobalParametersImpl(clientObject.getGlobalParameters(), this);
+ }
+ return globalParameters;
+ }
+
/**
* @return Wrapped service client DataFactoryManagementClient providing direct access to the underlying
* auto-generated API implementation, based on Azure REST API.
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/DataFactoryManagementClient.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/DataFactoryManagementClient.java
index e3bd4205f845..6e9bbb0433f3 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/DataFactoryManagementClient.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/DataFactoryManagementClient.java
@@ -183,4 +183,11 @@ public interface DataFactoryManagementClient {
* @return the PrivateLinkResourcesClient object.
*/
PrivateLinkResourcesClient getPrivateLinkResources();
+
+ /**
+ * Gets the GlobalParametersClient object to access its operations.
+ *
+ * @return the GlobalParametersClient object.
+ */
+ GlobalParametersClient getGlobalParameters();
}
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/GlobalParametersClient.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/GlobalParametersClient.java
new file mode 100644
index 000000000000..c40f5181cd5d
--- /dev/null
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/GlobalParametersClient.java
@@ -0,0 +1,142 @@
+// 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;
+
+import com.azure.core.annotation.ReturnType;
+import com.azure.core.annotation.ServiceMethod;
+import com.azure.core.http.rest.PagedIterable;
+import com.azure.core.http.rest.Response;
+import com.azure.core.util.Context;
+import com.azure.resourcemanager.datafactory.fluent.models.GlobalParameterResourceInner;
+
+/** An instance of this class provides access to all the operations defined in GlobalParametersClient. */
+public interface GlobalParametersClient {
+ /**
+ * Lists Global parameters.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param factoryName The factory name.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a list of Global parameters as paginated response with {@link PagedIterable}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ PagedIterable listByFactory(String resourceGroupName, String factoryName);
+
+ /**
+ * Lists Global parameters.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param factoryName The factory name.
+ * @param context The context to associate with this operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a list of Global parameters as paginated response with {@link PagedIterable}.
+ */
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ PagedIterable listByFactory(
+ String resourceGroupName, String factoryName, Context context);
+
+ /**
+ * Gets a Global parameter.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param factoryName The factory name.
+ * @param globalParameterName The global parameter name.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a Global parameter.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ GlobalParameterResourceInner get(String resourceGroupName, String factoryName, String globalParameterName);
+
+ /**
+ * Gets a Global parameter.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param factoryName The factory name.
+ * @param globalParameterName The global parameter name.
+ * @param context The context to associate with this operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a Global parameter along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ Response getWithResponse(
+ String resourceGroupName, String factoryName, String globalParameterName, Context context);
+
+ /**
+ * Creates or updates a Global parameter.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param factoryName The factory name.
+ * @param globalParameterName The global parameter name.
+ * @param defaultParameter Global parameter resource definition.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return global parameters resource type.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ GlobalParameterResourceInner createOrUpdate(
+ String resourceGroupName,
+ String factoryName,
+ String globalParameterName,
+ GlobalParameterResourceInner defaultParameter);
+
+ /**
+ * Creates or updates a Global parameter.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param factoryName The factory name.
+ * @param globalParameterName The global parameter name.
+ * @param defaultParameter Global parameter resource definition.
+ * @param context The context to associate with this operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return global parameters resource type along with {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ Response createOrUpdateWithResponse(
+ String resourceGroupName,
+ String factoryName,
+ String globalParameterName,
+ GlobalParameterResourceInner defaultParameter,
+ Context context);
+
+ /**
+ * Deletes a Global parameter.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param factoryName The factory name.
+ * @param globalParameterName The global parameter name.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ void delete(String resourceGroupName, String factoryName, String globalParameterName);
+
+ /**
+ * Deletes a Global parameter.
+ *
+ * @param resourceGroupName The resource group name.
+ * @param factoryName The factory name.
+ * @param globalParameterName The global parameter name.
+ * @param context The context to associate with this operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the {@link Response}.
+ */
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ Response deleteWithResponse(
+ String resourceGroupName, String factoryName, String globalParameterName, Context context);
+}
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/ExecuteDataFlowActivityTypeProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/ExecuteDataFlowActivityTypeProperties.java
index dda012dce81b..878b0676a069 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/ExecuteDataFlowActivityTypeProperties.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/ExecuteDataFlowActivityTypeProperties.java
@@ -63,6 +63,13 @@ public class ExecuteDataFlowActivityTypeProperties {
@JsonProperty(value = "runConcurrently")
private Object runConcurrently;
+ /*
+ * Specify number of parallel staging for sources applicable to the sink.
+ * Type: integer (or Expression with resultType integer)
+ */
+ @JsonProperty(value = "sourceStagingConcurrency")
+ private Object sourceStagingConcurrency;
+
/**
* Get the dataFlow property: Data flow reference.
*
@@ -210,6 +217,28 @@ public ExecuteDataFlowActivityTypeProperties withRunConcurrently(Object runConcu
return this;
}
+ /**
+ * Get the sourceStagingConcurrency property: Specify number of parallel staging for sources applicable to the sink.
+ * Type: integer (or Expression with resultType integer).
+ *
+ * @return the sourceStagingConcurrency value.
+ */
+ public Object sourceStagingConcurrency() {
+ return this.sourceStagingConcurrency;
+ }
+
+ /**
+ * Set the sourceStagingConcurrency property: Specify number of parallel staging for sources applicable to the sink.
+ * Type: integer (or Expression with resultType integer).
+ *
+ * @param sourceStagingConcurrency the sourceStagingConcurrency value to set.
+ * @return the ExecuteDataFlowActivityTypeProperties object itself.
+ */
+ public ExecuteDataFlowActivityTypeProperties withSourceStagingConcurrency(Object sourceStagingConcurrency) {
+ this.sourceStagingConcurrency = sourceStagingConcurrency;
+ return this;
+ }
+
/**
* Validates the instance.
*
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 ecef67d34b9a..f7c6206e9dc2 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
@@ -125,6 +125,13 @@ public ExecutePowerQueryActivityTypeProperties withRunConcurrently(Object runCon
return this;
}
+ /** {@inheritDoc} */
+ @Override
+ public ExecutePowerQueryActivityTypeProperties withSourceStagingConcurrency(Object sourceStagingConcurrency) {
+ super.withSourceStagingConcurrency(sourceStagingConcurrency);
+ return this;
+ }
+
/**
* Validates the instance.
*
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FactoryInner.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FactoryInner.java
index d32c90980cb6..8f9d8c0046de 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FactoryInner.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FactoryInner.java
@@ -11,6 +11,7 @@
import com.azure.resourcemanager.datafactory.models.FactoryRepoConfiguration;
import com.azure.resourcemanager.datafactory.models.GlobalParameterSpecification;
import com.azure.resourcemanager.datafactory.models.PublicNetworkAccess;
+import com.azure.resourcemanager.datafactory.models.PurviewConfiguration;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
@@ -153,6 +154,29 @@ public String version() {
return this.innerProperties() == null ? null : this.innerProperties().version();
}
+ /**
+ * Get the purviewConfiguration property: Purview information of the factory.
+ *
+ * @return the purviewConfiguration value.
+ */
+ public PurviewConfiguration purviewConfiguration() {
+ return this.innerProperties() == null ? null : this.innerProperties().purviewConfiguration();
+ }
+
+ /**
+ * Set the purviewConfiguration property: Purview information of the factory.
+ *
+ * @param purviewConfiguration the purviewConfiguration value to set.
+ * @return the FactoryInner object itself.
+ */
+ public FactoryInner withPurviewConfiguration(PurviewConfiguration purviewConfiguration) {
+ if (this.innerProperties() == null) {
+ this.innerProperties = new FactoryProperties();
+ }
+ this.innerProperties().withPurviewConfiguration(purviewConfiguration);
+ return this;
+ }
+
/**
* Get the repoConfiguration property: Git repo information of the factory.
*
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FactoryProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FactoryProperties.java
index f00eebde9a88..67a3568b15f6 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FactoryProperties.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FactoryProperties.java
@@ -9,6 +9,7 @@
import com.azure.resourcemanager.datafactory.models.FactoryRepoConfiguration;
import com.azure.resourcemanager.datafactory.models.GlobalParameterSpecification;
import com.azure.resourcemanager.datafactory.models.PublicNetworkAccess;
+import com.azure.resourcemanager.datafactory.models.PurviewConfiguration;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.time.OffsetDateTime;
@@ -35,6 +36,12 @@ public final class FactoryProperties {
@JsonProperty(value = "version", access = JsonProperty.Access.WRITE_ONLY)
private String version;
+ /*
+ * Purview information of the factory.
+ */
+ @JsonProperty(value = "purviewConfiguration")
+ private PurviewConfiguration purviewConfiguration;
+
/*
* Git repo information of the factory.
*/
@@ -87,6 +94,26 @@ public String version() {
return this.version;
}
+ /**
+ * Get the purviewConfiguration property: Purview information of the factory.
+ *
+ * @return the purviewConfiguration value.
+ */
+ public PurviewConfiguration purviewConfiguration() {
+ return this.purviewConfiguration;
+ }
+
+ /**
+ * Set the purviewConfiguration property: Purview information of the factory.
+ *
+ * @param purviewConfiguration the purviewConfiguration value to set.
+ * @return the FactoryProperties object itself.
+ */
+ public FactoryProperties withPurviewConfiguration(PurviewConfiguration purviewConfiguration) {
+ this.purviewConfiguration = purviewConfiguration;
+ return this;
+ }
+
/**
* Get the repoConfiguration property: Git repo information of the factory.
*
@@ -173,6 +200,9 @@ public FactoryProperties withPublicNetworkAccess(PublicNetworkAccess publicNetwo
* @throws IllegalArgumentException thrown if the instance is not valid.
*/
public void validate() {
+ if (purviewConfiguration() != null) {
+ purviewConfiguration().validate();
+ }
if (repoConfiguration() != null) {
repoConfiguration().validate();
}
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/GlobalParameterResourceInner.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/GlobalParameterResourceInner.java
new file mode 100644
index 000000000000..916692af4bfe
--- /dev/null
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/GlobalParameterResourceInner.java
@@ -0,0 +1,121 @@
+// 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.management.SubResource;
+import com.azure.core.util.logging.ClientLogger;
+import com.azure.resourcemanager.datafactory.models.GlobalParameterSpecification;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.Map;
+
+/** Global parameters resource type. */
+@Fluent
+public final class GlobalParameterResourceInner extends SubResource {
+ /*
+ * Properties of the global parameter.
+ */
+ @JsonProperty(value = "properties", required = true)
+ @JsonInclude(value = JsonInclude.Include.NON_NULL, content = JsonInclude.Include.ALWAYS)
+ private Map properties;
+
+ /*
+ * The resource name.
+ */
+ @JsonProperty(value = "name", access = JsonProperty.Access.WRITE_ONLY)
+ private String name;
+
+ /*
+ * The resource type.
+ */
+ @JsonProperty(value = "type", access = JsonProperty.Access.WRITE_ONLY)
+ private String type;
+
+ /*
+ * Etag identifies change in the resource.
+ */
+ @JsonProperty(value = "etag", access = JsonProperty.Access.WRITE_ONLY)
+ private String etag;
+
+ /**
+ * Get the properties property: Properties of the global parameter.
+ *
+ * @return the properties value.
+ */
+ public Map properties() {
+ return this.properties;
+ }
+
+ /**
+ * Set the properties property: Properties of the global parameter.
+ *
+ * @param properties the properties value to set.
+ * @return the GlobalParameterResourceInner object itself.
+ */
+ public GlobalParameterResourceInner withProperties(Map properties) {
+ this.properties = properties;
+ return this;
+ }
+
+ /**
+ * Get the name property: The resource name.
+ *
+ * @return the name value.
+ */
+ public String name() {
+ return this.name;
+ }
+
+ /**
+ * Get the type property: The resource type.
+ *
+ * @return the type value.
+ */
+ public String type() {
+ return this.type;
+ }
+
+ /**
+ * Get the etag property: Etag identifies change in the resource.
+ *
+ * @return the etag value.
+ */
+ public String etag() {
+ return this.etag;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public GlobalParameterResourceInner withId(String id) {
+ super.withId(id);
+ return this;
+ }
+
+ /**
+ * Validates the instance.
+ *
+ * @throws IllegalArgumentException thrown if the instance is not valid.
+ */
+ public void validate() {
+ if (properties() == null) {
+ throw LOGGER
+ .logExceptionAsError(
+ new IllegalArgumentException(
+ "Missing required property properties in model GlobalParameterResourceInner"));
+ } else {
+ properties()
+ .values()
+ .forEach(
+ e -> {
+ if (e != null) {
+ e.validate();
+ }
+ });
+ }
+ }
+
+ private static final ClientLogger LOGGER = new ClientLogger(GlobalParameterResourceInner.class);
+}
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/ActivityRunsClientImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/ActivityRunsClientImpl.java
index 0440d2dbb186..38d19cc1a463 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/ActivityRunsClientImpl.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/ActivityRunsClientImpl.java
@@ -211,14 +211,7 @@ private Mono> queryByPipelineRunWithRes
private Mono queryByPipelineRunAsync(
String resourceGroupName, String factoryName, String runId, RunFilterParameters filterParameters) {
return queryByPipelineRunWithResponseAsync(resourceGroupName, factoryName, runId, filterParameters)
- .flatMap(
- (Response res) -> {
- if (res.getValue() != null) {
- return Mono.just(res.getValue());
- } else {
- return Mono.empty();
- }
- });
+ .flatMap(res -> Mono.justOrEmpty(res.getValue()));
}
/**
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFactoryManagementClientImpl.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFactoryManagementClientImpl.java
index db43280b04a1..bc13e3a55864 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFactoryManagementClientImpl.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/implementation/DataFactoryManagementClientImpl.java
@@ -15,6 +15,7 @@
import com.azure.core.management.polling.PollResult;
import com.azure.core.management.polling.PollerFactory;
import com.azure.core.util.Context;
+import com.azure.core.util.CoreUtils;
import com.azure.core.util.logging.ClientLogger;
import com.azure.core.util.polling.AsyncPollResponse;
import com.azure.core.util.polling.LongRunningOperationStatus;
@@ -28,6 +29,7 @@
import com.azure.resourcemanager.datafactory.fluent.DatasetsClient;
import com.azure.resourcemanager.datafactory.fluent.ExposureControlsClient;
import com.azure.resourcemanager.datafactory.fluent.FactoriesClient;
+import com.azure.resourcemanager.datafactory.fluent.GlobalParametersClient;
import com.azure.resourcemanager.datafactory.fluent.IntegrationRuntimeNodesClient;
import com.azure.resourcemanager.datafactory.fluent.IntegrationRuntimeObjectMetadatasClient;
import com.azure.resourcemanager.datafactory.fluent.IntegrationRuntimesClient;
@@ -48,7 +50,6 @@
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.time.Duration;
-import java.util.Map;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@@ -367,6 +368,18 @@ public PrivateLinkResourcesClient getPrivateLinkResources() {
return this.privateLinkResources;
}
+ /** The GlobalParametersClient object to access its operations. */
+ private final GlobalParametersClient globalParameters;
+
+ /**
+ * Gets the GlobalParametersClient object to access its operations.
+ *
+ * @return the GlobalParametersClient object.
+ */
+ public GlobalParametersClient getGlobalParameters() {
+ return this.globalParameters;
+ }
+
/**
* Initializes an instance of DataFactoryManagementClient client.
*
@@ -410,6 +423,7 @@ public PrivateLinkResourcesClient getPrivateLinkResources() {
this.privateEndPointConnections = new PrivateEndPointConnectionsClientImpl(this);
this.privateEndpointConnectionOperations = new PrivateEndpointConnectionOperationsClientImpl(this);
this.privateLinkResources = new PrivateLinkResourcesClientImpl(this);
+ this.globalParameters = new GlobalParametersClientImpl(this);
}
/**
@@ -428,10 +442,7 @@ public Context getContext() {
* @return the merged context.
*/
public Context mergeContext(Context context) {
- for (Map.Entry