Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
112 changes: 108 additions & 4 deletions sdk/datafactory/azure-resourcemanager-datafactory/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,14 +1,118 @@
# Release History

## 1.1.0-beta.1 (Unreleased)
## 1.0.0-beta.1 (2025-03-03)

### Features Added
- 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).

### Breaking Changes

### Bugs Fixed
#### `models.Factories` was modified

* `list(com.azure.core.util.Context)` was removed
* `list()` was removed

### Features Added

* `models.GreenplumAuthenticationType` was added

### Other Changes
* `models.TeradataSink` was added

* `models.OracleAuthenticationType` was added

* `models.TeradataImportCommand` was added

#### `models.GreenplumLinkedService` was modified

* `withSslMode(java.lang.Object)` was added
* `withPassword(models.SecretBase)` was added
* `commandTimeout()` was added
* `database()` was added
* `password()` was added
* `host()` was added
* `withAuthenticationType(models.GreenplumAuthenticationType)` was added
* `withCommandTimeout(java.lang.Object)` was added
* `authenticationType()` was added
* `port()` was added
* `withConnectionTimeout(java.lang.Object)` was added
* `username()` was added
* `withDatabase(java.lang.Object)` was added
* `withUsername(java.lang.Object)` was added
* `withPort(java.lang.Object)` was added
* `withHost(java.lang.Object)` was added
* `connectionTimeout()` was added
* `sslMode()` was added

#### `models.TeradataLinkedService` was modified

* `httpsPortNumber()` was added
* `sslMode()` was added
* `withCharacterSet(java.lang.Object)` was added
* `withHttpsPortNumber(java.lang.Object)` was added
* `withPortNumber(java.lang.Object)` was added
* `withSslMode(java.lang.Object)` was added
* `portNumber()` was added
* `withMaxRespSize(java.lang.Object)` was added
* `maxRespSize()` was added
* `characterSet()` was added
* `withUseDataEncryption(java.lang.Object)` was added
* `useDataEncryption()` was added

#### `models.TypeConversionSettings` was modified

* `withDateFormat(java.lang.Object)` was added
* `dateFormat()` was added
* `timeFormat()` was added
* `withTimeFormat(java.lang.Object)` was added

#### `models.AzurePostgreSqlLinkedService` was modified

* `withServicePrincipalEmbeddedCert(models.SecretBase)` was added
* `servicePrincipalKey()` was added
* `withServicePrincipalEmbeddedCertPassword(models.SecretBase)` was added
* `withServicePrincipalKey(models.SecretBase)` was added
* `servicePrincipalEmbeddedCert()` was added
* `withCredential(models.CredentialReference)` was added
* `servicePrincipalId()` was added
* `servicePrincipalEmbeddedCertPassword()` was added
* `azureCloudType()` was added
* `withTenant(java.lang.Object)` was added
* `withServicePrincipalCredentialType(java.lang.Object)` was added
* `credential()` was added
* `tenant()` was added
* `withAzureCloudType(java.lang.Object)` was added
* `withServicePrincipalId(java.lang.Object)` was added
* `servicePrincipalCredentialType()` was added

#### `models.OracleLinkedService` was modified

* `withSupportV1DataTypes(java.lang.Object)` was added
* `enableBulkLoad()` was added
* `withCryptoChecksumClient(java.lang.Object)` was added
* `withServer(java.lang.Object)` was added
* `encryptionClient()` was added
* `cryptoChecksumClient()` was added
* `withInitialLobFetchSize(java.lang.Object)` was added
* `fetchSize()` was added
* `withAuthenticationType(models.OracleAuthenticationType)` was added
* `withEncryptionClient(java.lang.Object)` was added
* `initializationString()` was added
* `supportV1DataTypes()` was added
* `initialLobFetchSize()` was added
* `statementCacheSize()` was added
* `fetchTswtzAsTimestamp()` was added
* `withInitializationString(java.lang.Object)` was added
* `withEnableBulkLoad(java.lang.Object)` was added
* `withEncryptionTypesClient(java.lang.Object)` was added
* `username()` was added
* `encryptionTypesClient()` was added
* `authenticationType()` was added
* `withFetchTswtzAsTimestamp(java.lang.Object)` was added
* `server()` was added
* `withCryptoChecksumTypesClient(java.lang.Object)` was added
* `withStatementCacheSize(java.lang.Object)` was added
* `cryptoChecksumTypesClient()` was added
* `withFetchSize(java.lang.Object)` was added
* `withUsername(java.lang.Object)` was added

## 1.0.0 (2024-12-16)

Expand Down
14 changes: 6 additions & 8 deletions sdk/datafactory/azure-resourcemanager-datafactory/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ Various documentation is available to help you get started
<dependency>
<groupId>com.azure.resourcemanager</groupId>
<artifactId>azure-resourcemanager-datafactory</artifactId>
<version>1.0.0</version>
<version>1.1.0-beta.1</version>
</dependency>
```
[//]: # ({x-version-update-end})
Expand All @@ -52,15 +52,15 @@ Azure subscription ID can be configured via `AZURE_SUBSCRIPTION_ID` environment
Assuming the use of the `DefaultAzureCredential` credential class, the client can be authenticated using the following code:

```java
AzureProfile profile = new AzureProfile(AzureEnvironment.AZURE);
AzureProfile profile = new AzureProfile(AzureCloud.AZURE_PUBLIC_CLOUD);
TokenCredential credential = new DefaultAzureCredentialBuilder()
.authorityHost(profile.getEnvironment().getActiveDirectoryEndpoint())
.build();
DataFactoryManager manager = DataFactoryManager
.authenticate(credential, profile);
```

The sample code assumes global Azure. Please change `AzureEnvironment.AZURE` variable if otherwise.
The sample code assumes global Azure. Please change the `AzureCloud.AZURE_PUBLIC_CLOUD` variable if otherwise.

See [Authentication][authenticate] for more options.

Expand All @@ -73,19 +73,19 @@ See [API design][design] for general introduction on design and key concepts on
```java
// storage account
StorageAccount storageAccount = storageManager.storageAccounts()
.define(STORAGE_ACCOUNT)
.define(storageAccountName)
.withRegion(REGION)
.withExistingResourceGroup(resourceGroup)
.create();
final String storageAccountKey = storageAccount.getKeys().iterator().next().value();
final String connectionString
= getStorageConnectionString(STORAGE_ACCOUNT, storageAccountKey, storageManager.environment());
= getStorageConnectionString(storageAccountName, storageAccountKey, storageManager.environment());

// container
final String containerName = "adf";
storageManager.blobContainers()
.defineContainer(containerName)
.withExistingStorageAccount(resourceGroup, STORAGE_ACCOUNT)
.withExistingStorageAccount(resourceGroup, storageAccountName)
.withPublicAccess(PublicAccess.NONE)
.create();

Expand Down Expand Up @@ -193,5 +193,3 @@ This project has adopted the [Microsoft Open Source Code of Conduct][coc]. For m
[cg]: https://github.com/Azure/azure-sdk-for-java/blob/main/CONTRIBUTING.md
[coc]: https://opensource.microsoft.com/codeofconduct/
[coc_faq]: https://opensource.microsoft.com/codeofconduct/faq/


23 changes: 0 additions & 23 deletions sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,6 @@
- [GetByResourceGroup](#factories_getbyresourcegroup)
- [GetDataPlaneAccess](#factories_getdataplaneaccess)
- [GetGitHubAccessToken](#factories_getgithubaccesstoken)
- [List](#factories_list)
- [ListByResourceGroup](#factories_listbyresourcegroup)
- [Update](#factories_update)

Expand Down Expand Up @@ -1330,28 +1329,6 @@ public final class FactoriesGetGitHubAccessTokenSamples {
}
```

### Factories_List

```java
/**
* Samples for Factories List.
*/
public final class FactoriesListSamples {
/*
* x-ms-original-file:
* specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Factories_List.json
*/
/**
* Sample code: Factories_List.
*
* @param manager Entry point to DataFactoryManager.
*/
public static void factoriesList(com.azure.resourcemanager.datafactory.DataFactoryManager manager) {
manager.factories().list(com.azure.core.util.Context.NONE);
}
}
```

### Factories_ListByResourceGroup

```java
Expand Down
1 change: 1 addition & 0 deletions sdk/datafactory/azure-resourcemanager-datafactory/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<jacoco.min.linecoverage>0</jacoco.min.linecoverage>
<jacoco.min.branchcoverage>0</jacoco.min.branchcoverage>
<revapi.skip>true</revapi.skip>
<spotless.skip>false</spotless.skip>
</properties>
<dependencies>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
import com.azure.core.http.policy.UserAgentPolicy;
import com.azure.core.management.profile.AzureProfile;
import com.azure.core.util.Configuration;
import com.azure.core.util.CoreUtils;
import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.datafactory.fluent.DataFactoryManagementClient;
import com.azure.resourcemanager.datafactory.implementation.ActivityRunsImpl;
Expand Down Expand Up @@ -75,6 +76,7 @@
import java.time.temporal.ChronoUnit;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;

Expand Down Expand Up @@ -182,6 +184,9 @@ public static Configurable configure() {
*/
public static final class Configurable {
private static final ClientLogger LOGGER = new ClientLogger(Configurable.class);
private static final String SDK_VERSION = "version";
private static final Map<String, String> PROPERTIES
= CoreUtils.getProperties("azure-resourcemanager-datafactory.properties");

private HttpClient httpClient;
private HttpLogOptions httpLogOptions;
Expand Down Expand Up @@ -289,12 +294,14 @@ public DataFactoryManager authenticate(TokenCredential credential, AzureProfile
Objects.requireNonNull(credential, "'credential' cannot be null.");
Objects.requireNonNull(profile, "'profile' cannot be null.");

String clientVersion = PROPERTIES.getOrDefault(SDK_VERSION, "UnknownVersion");

StringBuilder userAgentBuilder = new StringBuilder();
userAgentBuilder.append("azsdk-java")
.append("-")
.append("com.azure.resourcemanager.datafactory")
.append("/")
.append("1.0.0");
.append(clientVersion);
if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
userAgentBuilder.append(" (")
.append(Configuration.getGlobalConfiguration().get("java.version"))
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,28 +21,6 @@
* An instance of this class provides access to all the operations defined in FactoriesClient.
*/
public interface FactoriesClient {
/**
* Lists factories under the specified subscription.
*
* @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 factory resources as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable<FactoryInner> list();

/**
* Lists factories under the specified subscription.
*
* @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 factory resources as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable<FactoryInner> list(Context context);

/**
* Updates a factory's repo information.
*
Expand Down
Loading