diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/CHANGELOG.md b/sdk/datafactory/azure-resourcemanager-datafactory/CHANGELOG.md
index b9949d33e3b1..3a345260ae42 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.10 (Unreleased)
+## 1.0.0-beta.1 (2022-01-05)
+
+- 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 e86823e69e79..69178ff347eb 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.9
+ 1.0.0-beta.10
```
[//]: # ({x-version-update-end})
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 0111aa3e5384..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
@@ -251,7 +251,7 @@ public DataFactoryManager authenticate(TokenCredential credential, AzureProfile
.append("-")
.append("com.azure.resourcemanager.datafactory")
.append("/")
- .append("1.0.0-beta.9");
+ .append("1.0.0-beta.1");
if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
userAgentBuilder
.append(" (")
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/AzureBlobFSLinkedServiceTypeProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/AzureBlobFSLinkedServiceTypeProperties.java
index e73bc131a295..c570e1f06c11 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/AzureBlobFSLinkedServiceTypeProperties.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/AzureBlobFSLinkedServiceTypeProperties.java
@@ -75,6 +75,26 @@ public final class AzureBlobFSLinkedServiceTypeProperties {
@JsonProperty(value = "credential")
private CredentialReference credential;
+ /*
+ * The service principal credential type to use in Server-To-Server
+ * authentication. 'ServicePrincipalKey' for key/secret,
+ * 'ServicePrincipalCert' for certificate. Type: string (or Expression with
+ * resultType string).
+ */
+ @JsonProperty(value = "servicePrincipalCredentialType")
+ private Object servicePrincipalCredentialType;
+
+ /*
+ * The credential of the service principal object in Azure Active
+ * Directory. If servicePrincipalCredentialType is 'ServicePrincipalKey',
+ * servicePrincipalCredential can be SecureString or
+ * AzureKeyVaultSecretReference. If servicePrincipalCredentialType is
+ * 'ServicePrincipalCert', servicePrincipalCredential can only be
+ * AzureKeyVaultSecretReference.
+ */
+ @JsonProperty(value = "servicePrincipalCredential")
+ private SecretBase servicePrincipalCredential;
+
/**
* Get the url property: Endpoint for the Azure Data Lake Storage Gen2 service. Type: string (or Expression with
* resultType string).
@@ -251,6 +271,58 @@ public AzureBlobFSLinkedServiceTypeProperties withCredential(CredentialReference
return this;
}
+ /**
+ * Get the servicePrincipalCredentialType property: The service principal credential type to use in Server-To-Server
+ * authentication. 'ServicePrincipalKey' for key/secret, 'ServicePrincipalCert' for certificate. Type: string (or
+ * Expression with resultType string).
+ *
+ * @return the servicePrincipalCredentialType value.
+ */
+ public Object servicePrincipalCredentialType() {
+ return this.servicePrincipalCredentialType;
+ }
+
+ /**
+ * Set the servicePrincipalCredentialType property: The service principal credential type to use in Server-To-Server
+ * authentication. 'ServicePrincipalKey' for key/secret, 'ServicePrincipalCert' for certificate. Type: string (or
+ * Expression with resultType string).
+ *
+ * @param servicePrincipalCredentialType the servicePrincipalCredentialType value to set.
+ * @return the AzureBlobFSLinkedServiceTypeProperties object itself.
+ */
+ public AzureBlobFSLinkedServiceTypeProperties withServicePrincipalCredentialType(
+ Object servicePrincipalCredentialType) {
+ this.servicePrincipalCredentialType = servicePrincipalCredentialType;
+ return this;
+ }
+
+ /**
+ * Get the servicePrincipalCredential property: The credential of the service principal object in Azure Active
+ * Directory. If servicePrincipalCredentialType is 'ServicePrincipalKey', servicePrincipalCredential can be
+ * SecureString or AzureKeyVaultSecretReference. If servicePrincipalCredentialType is 'ServicePrincipalCert',
+ * servicePrincipalCredential can only be AzureKeyVaultSecretReference.
+ *
+ * @return the servicePrincipalCredential value.
+ */
+ public SecretBase servicePrincipalCredential() {
+ return this.servicePrincipalCredential;
+ }
+
+ /**
+ * Set the servicePrincipalCredential property: The credential of the service principal object in Azure Active
+ * Directory. If servicePrincipalCredentialType is 'ServicePrincipalKey', servicePrincipalCredential can be
+ * SecureString or AzureKeyVaultSecretReference. If servicePrincipalCredentialType is 'ServicePrincipalCert',
+ * servicePrincipalCredential can only be AzureKeyVaultSecretReference.
+ *
+ * @param servicePrincipalCredential the servicePrincipalCredential value to set.
+ * @return the AzureBlobFSLinkedServiceTypeProperties object itself.
+ */
+ public AzureBlobFSLinkedServiceTypeProperties withServicePrincipalCredential(
+ SecretBase servicePrincipalCredential) {
+ this.servicePrincipalCredential = servicePrincipalCredential;
+ return this;
+ }
+
/**
* Validates the instance.
*
@@ -269,5 +341,8 @@ public void validate() {
if (credential() != null) {
credential().validate();
}
+ if (servicePrincipalCredential() != null) {
+ servicePrincipalCredential().validate();
+ }
}
}
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/AzureDatabricksDetltaLakeLinkedServiceTypeProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/AzureDatabricksDetltaLakeLinkedServiceTypeProperties.java
index 574ae43888af..798960f8a84c 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/AzureDatabricksDetltaLakeLinkedServiceTypeProperties.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/AzureDatabricksDetltaLakeLinkedServiceTypeProperties.java
@@ -6,6 +6,7 @@
import com.azure.core.annotation.Fluent;
import com.azure.core.util.logging.ClientLogger;
+import com.azure.resourcemanager.datafactory.models.CredentialReference;
import com.azure.resourcemanager.datafactory.models.SecretBase;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
@@ -46,6 +47,19 @@ public final class AzureDatabricksDetltaLakeLinkedServiceTypeProperties {
@JsonProperty(value = "encryptedCredential")
private Object encryptedCredential;
+ /*
+ * The credential reference containing authentication information.
+ */
+ @JsonProperty(value = "credential")
+ private CredentialReference credential;
+
+ /*
+ * Workspace resource id for databricks REST API. Type: string (or
+ * Expression with resultType string).
+ */
+ @JsonProperty(value = "workspaceResourceId")
+ private Object workspaceResourceId;
+
/**
* Get the domain property: <REGION>.azuredatabricks.net, domain name of your Databricks deployment. Type:
* string (or Expression with resultType string).
@@ -136,6 +150,48 @@ public AzureDatabricksDetltaLakeLinkedServiceTypeProperties withEncryptedCredent
return this;
}
+ /**
+ * Get the credential property: The credential reference containing authentication information.
+ *
+ * @return the credential value.
+ */
+ public CredentialReference credential() {
+ return this.credential;
+ }
+
+ /**
+ * Set the credential property: The credential reference containing authentication information.
+ *
+ * @param credential the credential value to set.
+ * @return the AzureDatabricksDetltaLakeLinkedServiceTypeProperties object itself.
+ */
+ public AzureDatabricksDetltaLakeLinkedServiceTypeProperties withCredential(CredentialReference credential) {
+ this.credential = credential;
+ return this;
+ }
+
+ /**
+ * Get the workspaceResourceId property: Workspace resource id for databricks REST API. Type: string (or Expression
+ * with resultType string).
+ *
+ * @return the workspaceResourceId value.
+ */
+ public Object workspaceResourceId() {
+ return this.workspaceResourceId;
+ }
+
+ /**
+ * Set the workspaceResourceId property: Workspace resource id for databricks REST API. Type: string (or Expression
+ * with resultType string).
+ *
+ * @param workspaceResourceId the workspaceResourceId value to set.
+ * @return the AzureDatabricksDetltaLakeLinkedServiceTypeProperties object itself.
+ */
+ public AzureDatabricksDetltaLakeLinkedServiceTypeProperties withWorkspaceResourceId(Object workspaceResourceId) {
+ this.workspaceResourceId = workspaceResourceId;
+ return this;
+ }
+
/**
* Validates the instance.
*
@@ -152,5 +208,8 @@ public void validate() {
if (accessToken() != null) {
accessToken().validate();
}
+ if (credential() != null) {
+ credential().validate();
+ }
}
}
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/CosmosDbLinkedServiceTypeProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/CosmosDbLinkedServiceTypeProperties.java
index 0d6ce4dddb07..9340b43ec72e 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/CosmosDbLinkedServiceTypeProperties.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/CosmosDbLinkedServiceTypeProperties.java
@@ -8,6 +8,7 @@
import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.datafactory.models.CosmosDbConnectionMode;
import com.azure.resourcemanager.datafactory.models.CosmosDbServicePrincipalCredentialType;
+import com.azure.resourcemanager.datafactory.models.CredentialReference;
import com.azure.resourcemanager.datafactory.models.SecretBase;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
@@ -104,6 +105,12 @@ public final class CosmosDbLinkedServiceTypeProperties {
@JsonProperty(value = "encryptedCredential")
private Object encryptedCredential;
+ /*
+ * The credential reference containing authentication information.
+ */
+ @JsonProperty(value = "credential")
+ private CredentialReference credential;
+
/**
* Get the connectionString property: The connection string. Type: string, SecureString or
* AzureKeyVaultSecretReference.
@@ -353,6 +360,26 @@ public CosmosDbLinkedServiceTypeProperties withEncryptedCredential(Object encryp
return this;
}
+ /**
+ * Get the credential property: The credential reference containing authentication information.
+ *
+ * @return the credential value.
+ */
+ public CredentialReference credential() {
+ return this.credential;
+ }
+
+ /**
+ * Set the credential property: The credential reference containing authentication information.
+ *
+ * @param credential the credential value to set.
+ * @return the CosmosDbLinkedServiceTypeProperties object itself.
+ */
+ public CosmosDbLinkedServiceTypeProperties withCredential(CredentialReference credential) {
+ this.credential = credential;
+ return this;
+ }
+
/**
* Validates the instance.
*
@@ -365,5 +392,8 @@ public void validate() {
if (servicePrincipalCredential() != null) {
servicePrincipalCredential().validate();
}
+ if (credential() != null) {
+ credential().validate();
+ }
}
}
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/DynamicsLinkedServiceTypeProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/DynamicsLinkedServiceTypeProperties.java
index 0d9fbf1d44fa..bfbb43bc31fa 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/DynamicsLinkedServiceTypeProperties.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/DynamicsLinkedServiceTypeProperties.java
@@ -6,6 +6,7 @@
import com.azure.core.annotation.Fluent;
import com.azure.core.util.logging.ClientLogger;
+import com.azure.resourcemanager.datafactory.models.CredentialReference;
import com.azure.resourcemanager.datafactory.models.SecretBase;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
@@ -114,6 +115,12 @@ public final class DynamicsLinkedServiceTypeProperties {
@JsonProperty(value = "encryptedCredential")
private Object encryptedCredential;
+ /*
+ * The credential reference containing authentication information.
+ */
+ @JsonProperty(value = "credential")
+ private CredentialReference credential;
+
/**
* Get the deploymentType property: The deployment type of the Dynamics instance. 'Online' for Dynamics Online and
* 'OnPremisesWithIfd' for Dynamics on-premises with Ifd. Type: string (or Expression with resultType string).
@@ -387,6 +394,26 @@ public DynamicsLinkedServiceTypeProperties withEncryptedCredential(Object encryp
return this;
}
+ /**
+ * Get the credential property: The credential reference containing authentication information.
+ *
+ * @return the credential value.
+ */
+ public CredentialReference credential() {
+ return this.credential;
+ }
+
+ /**
+ * Set the credential property: The credential reference containing authentication information.
+ *
+ * @param credential the credential value to set.
+ * @return the DynamicsLinkedServiceTypeProperties object itself.
+ */
+ public DynamicsLinkedServiceTypeProperties withCredential(CredentialReference credential) {
+ this.credential = credential;
+ return this;
+ }
+
/**
* Validates the instance.
*
@@ -411,5 +438,8 @@ public void validate() {
if (servicePrincipalCredential() != null) {
servicePrincipalCredential().validate();
}
+ if (credential() != null) {
+ credential().validate();
+ }
}
}
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FailActivityTypeProperties.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FailActivityTypeProperties.java
new file mode 100644
index 000000000000..67fe20cf006b
--- /dev/null
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/fluent/models/FailActivityTypeProperties.java
@@ -0,0 +1,98 @@
+// 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.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** Fail activity properties. */
+@Fluent
+public final class FailActivityTypeProperties {
+ @JsonIgnore private final ClientLogger logger = new ClientLogger(FailActivityTypeProperties.class);
+
+ /*
+ * The error message that surfaced in the Fail activity. It can be dynamic
+ * content that's evaluated to a non empty/blank string at runtime. Type:
+ * string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "message", required = true)
+ private Object message;
+
+ /*
+ * The error code that categorizes the error type of the Fail activity. It
+ * can be dynamic content that's evaluated to a non empty/blank string at
+ * runtime. Type: string (or Expression with resultType string).
+ */
+ @JsonProperty(value = "errorCode", required = true)
+ private Object errorCode;
+
+ /**
+ * Get the message property: The error message that surfaced in the Fail activity. It can be dynamic content that's
+ * evaluated to a non empty/blank string at runtime. Type: string (or Expression with resultType string).
+ *
+ * @return the message value.
+ */
+ public Object message() {
+ return this.message;
+ }
+
+ /**
+ * Set the message property: The error message that surfaced in the Fail activity. It can be dynamic content that's
+ * evaluated to a non empty/blank string at runtime. Type: string (or Expression with resultType string).
+ *
+ * @param message the message value to set.
+ * @return the FailActivityTypeProperties object itself.
+ */
+ public FailActivityTypeProperties withMessage(Object message) {
+ this.message = message;
+ return this;
+ }
+
+ /**
+ * Get the errorCode property: The error code that categorizes the error type of the Fail activity. It can be
+ * dynamic content that's evaluated to a non empty/blank string at runtime. Type: string (or Expression with
+ * resultType string).
+ *
+ * @return the errorCode value.
+ */
+ public Object errorCode() {
+ return this.errorCode;
+ }
+
+ /**
+ * Set the errorCode property: The error code that categorizes the error type of the Fail activity. It can be
+ * dynamic content that's evaluated to a non empty/blank string at runtime. Type: string (or Expression with
+ * resultType string).
+ *
+ * @param errorCode the errorCode value to set.
+ * @return the FailActivityTypeProperties object itself.
+ */
+ public FailActivityTypeProperties withErrorCode(Object errorCode) {
+ this.errorCode = errorCode;
+ return this;
+ }
+
+ /**
+ * Validates the instance.
+ *
+ * @throws IllegalArgumentException thrown if the instance is not valid.
+ */
+ public void validate() {
+ if (message() == null) {
+ throw logger
+ .logExceptionAsError(
+ new IllegalArgumentException(
+ "Missing required property message in model FailActivityTypeProperties"));
+ }
+ if (errorCode() == null) {
+ throw logger
+ .logExceptionAsError(
+ new IllegalArgumentException(
+ "Missing required property errorCode in model FailActivityTypeProperties"));
+ }
+ }
+}
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/AzureBlobFSLinkedService.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/AzureBlobFSLinkedService.java
index 4095e9743d24..3ddc2db9be6a 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/AzureBlobFSLinkedService.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/AzureBlobFSLinkedService.java
@@ -264,6 +264,62 @@ public AzureBlobFSLinkedService withCredential(CredentialReference credential) {
return this;
}
+ /**
+ * Get the servicePrincipalCredentialType property: The service principal credential type to use in Server-To-Server
+ * authentication. 'ServicePrincipalKey' for key/secret, 'ServicePrincipalCert' for certificate. Type: string (or
+ * Expression with resultType string).
+ *
+ * @return the servicePrincipalCredentialType value.
+ */
+ public Object servicePrincipalCredentialType() {
+ return this.innerTypeProperties() == null ? null : this.innerTypeProperties().servicePrincipalCredentialType();
+ }
+
+ /**
+ * Set the servicePrincipalCredentialType property: The service principal credential type to use in Server-To-Server
+ * authentication. 'ServicePrincipalKey' for key/secret, 'ServicePrincipalCert' for certificate. Type: string (or
+ * Expression with resultType string).
+ *
+ * @param servicePrincipalCredentialType the servicePrincipalCredentialType value to set.
+ * @return the AzureBlobFSLinkedService object itself.
+ */
+ public AzureBlobFSLinkedService withServicePrincipalCredentialType(Object servicePrincipalCredentialType) {
+ if (this.innerTypeProperties() == null) {
+ this.innerTypeProperties = new AzureBlobFSLinkedServiceTypeProperties();
+ }
+ this.innerTypeProperties().withServicePrincipalCredentialType(servicePrincipalCredentialType);
+ return this;
+ }
+
+ /**
+ * Get the servicePrincipalCredential property: The credential of the service principal object in Azure Active
+ * Directory. If servicePrincipalCredentialType is 'ServicePrincipalKey', servicePrincipalCredential can be
+ * SecureString or AzureKeyVaultSecretReference. If servicePrincipalCredentialType is 'ServicePrincipalCert',
+ * servicePrincipalCredential can only be AzureKeyVaultSecretReference.
+ *
+ * @return the servicePrincipalCredential value.
+ */
+ public SecretBase servicePrincipalCredential() {
+ return this.innerTypeProperties() == null ? null : this.innerTypeProperties().servicePrincipalCredential();
+ }
+
+ /**
+ * Set the servicePrincipalCredential property: The credential of the service principal object in Azure Active
+ * Directory. If servicePrincipalCredentialType is 'ServicePrincipalKey', servicePrincipalCredential can be
+ * SecureString or AzureKeyVaultSecretReference. If servicePrincipalCredentialType is 'ServicePrincipalCert',
+ * servicePrincipalCredential can only be AzureKeyVaultSecretReference.
+ *
+ * @param servicePrincipalCredential the servicePrincipalCredential value to set.
+ * @return the AzureBlobFSLinkedService object itself.
+ */
+ public AzureBlobFSLinkedService withServicePrincipalCredential(SecretBase servicePrincipalCredential) {
+ if (this.innerTypeProperties() == null) {
+ this.innerTypeProperties = new AzureBlobFSLinkedServiceTypeProperties();
+ }
+ this.innerTypeProperties().withServicePrincipalCredential(servicePrincipalCredential);
+ return this;
+ }
+
/**
* Validates the instance.
*
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/AzureDatabricksDeltaLakeLinkedService.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/AzureDatabricksDeltaLakeLinkedService.java
index 6a9ad2a130e4..6b6f7648b140 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/AzureDatabricksDeltaLakeLinkedService.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/AzureDatabricksDeltaLakeLinkedService.java
@@ -167,6 +167,54 @@ public AzureDatabricksDeltaLakeLinkedService withEncryptedCredential(Object encr
return this;
}
+ /**
+ * Get the credential property: The credential reference containing authentication information.
+ *
+ * @return the credential value.
+ */
+ public CredentialReference credential() {
+ return this.innerTypeProperties() == null ? null : this.innerTypeProperties().credential();
+ }
+
+ /**
+ * Set the credential property: The credential reference containing authentication information.
+ *
+ * @param credential the credential value to set.
+ * @return the AzureDatabricksDeltaLakeLinkedService object itself.
+ */
+ public AzureDatabricksDeltaLakeLinkedService withCredential(CredentialReference credential) {
+ if (this.innerTypeProperties() == null) {
+ this.innerTypeProperties = new AzureDatabricksDetltaLakeLinkedServiceTypeProperties();
+ }
+ this.innerTypeProperties().withCredential(credential);
+ return this;
+ }
+
+ /**
+ * Get the workspaceResourceId property: Workspace resource id for databricks REST API. Type: string (or Expression
+ * with resultType string).
+ *
+ * @return the workspaceResourceId value.
+ */
+ public Object workspaceResourceId() {
+ return this.innerTypeProperties() == null ? null : this.innerTypeProperties().workspaceResourceId();
+ }
+
+ /**
+ * Set the workspaceResourceId property: Workspace resource id for databricks REST API. Type: string (or Expression
+ * with resultType string).
+ *
+ * @param workspaceResourceId the workspaceResourceId value to set.
+ * @return the AzureDatabricksDeltaLakeLinkedService object itself.
+ */
+ public AzureDatabricksDeltaLakeLinkedService withWorkspaceResourceId(Object workspaceResourceId) {
+ if (this.innerTypeProperties() == null) {
+ this.innerTypeProperties = new AzureDatabricksDetltaLakeLinkedServiceTypeProperties();
+ }
+ this.innerTypeProperties().withWorkspaceResourceId(workspaceResourceId);
+ return this;
+ }
+
/**
* Validates the instance.
*
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ControlActivity.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ControlActivity.java
index 5c3778b1dde1..948ba7ddd913 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ControlActivity.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/ControlActivity.java
@@ -25,6 +25,7 @@
@JsonSubTypes.Type(name = "Switch", value = SwitchActivity.class),
@JsonSubTypes.Type(name = "ForEach", value = ForEachActivity.class),
@JsonSubTypes.Type(name = "Wait", value = WaitActivity.class),
+ @JsonSubTypes.Type(name = "Fail", value = FailActivity.class),
@JsonSubTypes.Type(name = "Until", value = UntilActivity.class),
@JsonSubTypes.Type(name = "Validation", value = ValidationActivity.class),
@JsonSubTypes.Type(name = "Filter", value = FilterActivity.class),
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/CosmosDbLinkedService.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/CosmosDbLinkedService.java
index e4ac7efb4827..946395983fc5 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/CosmosDbLinkedService.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/CosmosDbLinkedService.java
@@ -346,6 +346,29 @@ public CosmosDbLinkedService withEncryptedCredential(Object encryptedCredential)
return this;
}
+ /**
+ * Get the credential property: The credential reference containing authentication information.
+ *
+ * @return the credential value.
+ */
+ public CredentialReference credential() {
+ return this.innerTypeProperties() == null ? null : this.innerTypeProperties().credential();
+ }
+
+ /**
+ * Set the credential property: The credential reference containing authentication information.
+ *
+ * @param credential the credential value to set.
+ * @return the CosmosDbLinkedService object itself.
+ */
+ public CosmosDbLinkedService withCredential(CredentialReference credential) {
+ if (this.innerTypeProperties() == null) {
+ this.innerTypeProperties = new CosmosDbLinkedServiceTypeProperties();
+ }
+ this.innerTypeProperties().withCredential(credential);
+ return this;
+ }
+
/**
* Validates the instance.
*
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DynamicsLinkedService.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DynamicsLinkedService.java
index 05f1a2d91ff7..728c0234340f 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DynamicsLinkedService.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/DynamicsLinkedService.java
@@ -372,6 +372,29 @@ public DynamicsLinkedService withEncryptedCredential(Object encryptedCredential)
return this;
}
+ /**
+ * Get the credential property: The credential reference containing authentication information.
+ *
+ * @return the credential value.
+ */
+ public CredentialReference credential() {
+ return this.innerTypeProperties() == null ? null : this.innerTypeProperties().credential();
+ }
+
+ /**
+ * Set the credential property: The credential reference containing authentication information.
+ *
+ * @param credential the credential value to set.
+ * @return the DynamicsLinkedService object itself.
+ */
+ public DynamicsLinkedService withCredential(CredentialReference credential) {
+ if (this.innerTypeProperties() == null) {
+ this.innerTypeProperties = new DynamicsLinkedServiceTypeProperties();
+ }
+ this.innerTypeProperties().withCredential(credential);
+ return this;
+ }
+
/**
* Validates the instance.
*
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/FailActivity.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/FailActivity.java
new file mode 100644
index 000000000000..05291c502202
--- /dev/null
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/FailActivity.java
@@ -0,0 +1,140 @@
+// 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.FailActivityTypeProperties;
+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.List;
+
+/**
+ * This activity will fail within its own scope and output a custom error message and error code. The error message and
+ * code can provided either as a string literal or as an expression that can be evaluated to a string at runtime. The
+ * activity scope can be the whole pipeline or a control activity (e.g. foreach, switch, until), if the fail activity is
+ * contained in it.
+ */
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
+@JsonTypeName("Fail")
+@Fluent
+public final class FailActivity extends ControlActivity {
+ @JsonIgnore private final ClientLogger logger = new ClientLogger(FailActivity.class);
+
+ /*
+ * Fail activity properties.
+ */
+ @JsonProperty(value = "typeProperties", required = true)
+ private FailActivityTypeProperties innerTypeProperties = new FailActivityTypeProperties();
+
+ /**
+ * Get the innerTypeProperties property: Fail activity properties.
+ *
+ * @return the innerTypeProperties value.
+ */
+ private FailActivityTypeProperties innerTypeProperties() {
+ return this.innerTypeProperties;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public FailActivity withName(String name) {
+ super.withName(name);
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public FailActivity withDescription(String description) {
+ super.withDescription(description);
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public FailActivity withDependsOn(List dependsOn) {
+ super.withDependsOn(dependsOn);
+ return this;
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public FailActivity withUserProperties(List userProperties) {
+ super.withUserProperties(userProperties);
+ return this;
+ }
+
+ /**
+ * Get the message property: The error message that surfaced in the Fail activity. It can be dynamic content that's
+ * evaluated to a non empty/blank string at runtime. Type: string (or Expression with resultType string).
+ *
+ * @return the message value.
+ */
+ public Object message() {
+ return this.innerTypeProperties() == null ? null : this.innerTypeProperties().message();
+ }
+
+ /**
+ * Set the message property: The error message that surfaced in the Fail activity. It can be dynamic content that's
+ * evaluated to a non empty/blank string at runtime. Type: string (or Expression with resultType string).
+ *
+ * @param message the message value to set.
+ * @return the FailActivity object itself.
+ */
+ public FailActivity withMessage(Object message) {
+ if (this.innerTypeProperties() == null) {
+ this.innerTypeProperties = new FailActivityTypeProperties();
+ }
+ this.innerTypeProperties().withMessage(message);
+ return this;
+ }
+
+ /**
+ * Get the errorCode property: The error code that categorizes the error type of the Fail activity. It can be
+ * dynamic content that's evaluated to a non empty/blank string at runtime. Type: string (or Expression with
+ * resultType string).
+ *
+ * @return the errorCode value.
+ */
+ public Object errorCode() {
+ return this.innerTypeProperties() == null ? null : this.innerTypeProperties().errorCode();
+ }
+
+ /**
+ * Set the errorCode property: The error code that categorizes the error type of the Fail activity. It can be
+ * dynamic content that's evaluated to a non empty/blank string at runtime. Type: string (or Expression with
+ * resultType string).
+ *
+ * @param errorCode the errorCode value to set.
+ * @return the FailActivity object itself.
+ */
+ public FailActivity withErrorCode(Object errorCode) {
+ if (this.innerTypeProperties() == null) {
+ this.innerTypeProperties = new FailActivityTypeProperties();
+ }
+ this.innerTypeProperties().withErrorCode(errorCode);
+ return this;
+ }
+
+ /**
+ * Validates the instance.
+ *
+ * @throws IllegalArgumentException thrown if the instance is not valid.
+ */
+ @Override
+ public void validate() {
+ super.validate();
+ if (innerTypeProperties() == null) {
+ throw logger
+ .logExceptionAsError(
+ new IllegalArgumentException(
+ "Missing required property innerTypeProperties in model FailActivity"));
+ } else {
+ innerTypeProperties().validate();
+ }
+ }
+}
diff --git a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/LinkedIntegrationRuntimeRbacAuthorization.java b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/LinkedIntegrationRuntimeRbacAuthorization.java
index 44819a477ad4..62d63a45fdf0 100644
--- a/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/LinkedIntegrationRuntimeRbacAuthorization.java
+++ b/sdk/datafactory/azure-resourcemanager-datafactory/src/main/java/com/azure/resourcemanager/datafactory/models/LinkedIntegrationRuntimeRbacAuthorization.java
@@ -24,6 +24,12 @@ public final class LinkedIntegrationRuntimeRbacAuthorization extends LinkedInteg
@JsonProperty(value = "resourceId", required = true)
private String resourceId;
+ /*
+ * The credential reference containing authentication information.
+ */
+ @JsonProperty(value = "credential")
+ private CredentialReference credential;
+
/**
* Get the resourceId property: The resource identifier of the integration runtime to be shared.
*
@@ -44,6 +50,26 @@ public LinkedIntegrationRuntimeRbacAuthorization withResourceId(String resourceI
return this;
}
+ /**
+ * Get the credential property: The credential reference containing authentication information.
+ *
+ * @return the credential value.
+ */
+ public CredentialReference credential() {
+ return this.credential;
+ }
+
+ /**
+ * Set the credential property: The credential reference containing authentication information.
+ *
+ * @param credential the credential value to set.
+ * @return the LinkedIntegrationRuntimeRbacAuthorization object itself.
+ */
+ public LinkedIntegrationRuntimeRbacAuthorization withCredential(CredentialReference credential) {
+ this.credential = credential;
+ return this;
+ }
+
/**
* Validates the instance.
*
@@ -58,5 +84,8 @@ public void validate() {
new IllegalArgumentException(
"Missing required property resourceId in model LinkedIntegrationRuntimeRbacAuthorization"));
}
+ if (credential() != null) {
+ credential().validate();
+ }
}
}