Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[AutoPR azure-resourcemanager-datafactory] [Hub Generated] Publish private branch 'datafactory/vekandib/disablepublish-swaggerchange' #2357

Closed
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
  •  
  •  
  •  
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
# Release History

## 1.0.0-beta.18 (Unreleased)
## 1.0.0-beta.1 (2022-10-13)

- 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

Expand Down
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-beta.17</version>
<version>1.0.0-beta.18</version>
</dependency>
```
[//]: # ({x-version-update-end})
Expand Down
82 changes: 55 additions & 27 deletions sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md
Original file line number Diff line number Diff line change
Expand Up @@ -520,19 +520,32 @@ public final class DataFlowsCreateOrUpdateSamples {
new DataFlowSink()
.withName("CADSink")
.withDataset(new DatasetReference().withReferenceName("CADOutput"))))
.withScript(
"source(output(PreviousConversionRate as double,Country as string,DateTime1 as"
+ " string,CurrentConversionRate as double),allowSchemaDrift: false,validateSchema: false)"
+ " ~> USDCurrency\n"
+ "source(output(PreviousConversionRate as double,Country as string,DateTime1 as"
+ " 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"
+ "NewCurrencyColumn split(Country == 'USD',Country == 'CAD',disjoint: false) ~>"
+ " ConditionalSplit1@(USD, CAD)\n"
+ "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink\n"
+ "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink"))
.withScriptLines(
Arrays
.asList(
"source(output(",
"PreviousConversionRate as double,",
"Country as string,",
"DateTime1 as string,",
"CurrentConversionRate as double",
"),",
"allowSchemaDrift: false,",
"validateSchema: false) ~> USDCurrency",
"source(output(",
"PreviousConversionRate as double,",
"Country as string,",
"DateTime1 as string,",
"CurrentConversionRate as double",
"),",
"allowSchemaDrift: true,",
"validateSchema: false) ~> CADSource",
"USDCurrency, CADSource union(byName: true)~> Union",
"Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~>"
+ " NewCurrencyColumn",
"NewCurrencyColumn split(Country == 'USD',",
"Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)",
"ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink",
"ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink")))
.create();
}

Expand Down Expand Up @@ -575,19 +588,32 @@ public final class DataFlowsCreateOrUpdateSamples {
new DataFlowSink()
.withName("CADSink")
.withDataset(new DatasetReference().withReferenceName("CADOutput"))))
.withScript(
"source(output(PreviousConversionRate as double,Country as string,DateTime1 as"
+ " string,CurrentConversionRate as double),allowSchemaDrift: false,validateSchema: false)"
+ " ~> USDCurrency\n"
+ "source(output(PreviousConversionRate as double,Country as string,DateTime1 as"
+ " 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"
+ "NewCurrencyColumn split(Country == 'USD',Country == 'CAD',disjoint: false) ~>"
+ " ConditionalSplit1@(USD, CAD)\n"
+ "ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink\n"
+ "ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink"))
.withScriptLines(
Arrays
.asList(
"source(output(",
"PreviousConversionRate as double,",
"Country as string,",
"DateTime1 as string,",
"CurrentConversionRate as double",
"),",
"allowSchemaDrift: false,",
"validateSchema: false) ~> USDCurrency",
"source(output(",
"PreviousConversionRate as double,",
"Country as string,",
"DateTime1 as string,",
"CurrentConversionRate as double",
"),",
"allowSchemaDrift: true,",
"validateSchema: false) ~> CADSource",
"USDCurrency, CADSource union(byName: true)~> Union",
"Union derive(NewCurrencyRate = round(CurrentConversionRate*1.25)) ~>"
+ " NewCurrencyColumn",
"NewCurrencyColumn split(Country == 'USD',",
"Country == 'CAD',disjoint: false) ~> ConditionalSplit1@(USD, CAD)",
"ConditionalSplit1@USD sink(saveMode:'overwrite' ) ~> USDSink",
"ConditionalSplit1@CAD sink(saveMode:'overwrite' ) ~> CADSink")))
.apply();
}
}
Expand Down Expand Up @@ -1024,7 +1050,9 @@ public final class FactoriesDeleteSamples {
* @param manager Entry point to DataFactoryManager.
*/
public static void factoriesDelete(com.azure.resourcemanager.datafactory.DataFactoryManager manager) {
manager.factories().deleteWithResponse("exampleResourceGroup", "exampleFactoryName", Context.NONE);
manager
.factories()
.deleteByResourceGroupWithResponse("exampleResourceGroup", "exampleFactoryName", Context.NONE);
}
}
```
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -286,7 +286,7 @@ public DataFactoryManager authenticate(TokenCredential credential, AzureProfile
.append("-")
.append("com.azure.resourcemanager.datafactory")
.append("/")
.append("1.0.0-beta.17");
.append("1.0.0-beta.1");
if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
userAgentBuilder
.append(" (")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,14 +20,19 @@ public interface ActivityRunsClient {
* @param factoryName The factory name.
* @param runId The pipeline run identifier.
* @param filterParameters Parameters to filter the activity runs.
* @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 activity runs.
* @return a list activity runs along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
ActivityRunsQueryResponseInner queryByPipelineRun(
String resourceGroupName, String factoryName, String runId, RunFilterParameters filterParameters);
Response<ActivityRunsQueryResponseInner> queryByPipelineRunWithResponse(
String resourceGroupName,
String factoryName,
String runId,
RunFilterParameters filterParameters,
Context context);

/**
* Query activity runs based on input filter conditions.
Expand All @@ -36,17 +41,12 @@ ActivityRunsQueryResponseInner queryByPipelineRun(
* @param factoryName The factory name.
* @param runId The pipeline run identifier.
* @param filterParameters Parameters to filter the activity runs.
* @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 activity runs along with {@link Response}.
* @return a list activity runs.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response<ActivityRunsQueryResponseInner> queryByPipelineRunWithResponse(
String resourceGroupName,
String factoryName,
String runId,
RunFilterParameters filterParameters,
Context context);
ActivityRunsQueryResponseInner queryByPipelineRun(
String resourceGroupName, String factoryName, String runId, RunFilterParameters filterParameters);
}
Original file line number Diff line number Diff line change
Expand Up @@ -119,59 +119,59 @@ PagedIterable<DataFlowDebugSessionInfoInner> queryByFactory(
* @param resourceGroupName The resource group name.
* @param factoryName The factory name.
* @param request Data flow debug session definition with debug content.
* @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 response body structure for starting data flow debug session.
* @return response body structure for starting data flow debug session along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
AddDataFlowToDebugSessionResponseInner addDataFlow(
String resourceGroupName, String factoryName, DataFlowDebugPackage request);
Response<AddDataFlowToDebugSessionResponseInner> addDataFlowWithResponse(
String resourceGroupName, String factoryName, DataFlowDebugPackage request, Context context);

/**
* Add a data flow into debug session.
*
* @param resourceGroupName The resource group name.
* @param factoryName The factory name.
* @param request Data flow debug session definition with debug content.
* @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 response body structure for starting data flow debug session along with {@link Response}.
* @return response body structure for starting data flow debug session.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response<AddDataFlowToDebugSessionResponseInner> addDataFlowWithResponse(
String resourceGroupName, String factoryName, DataFlowDebugPackage request, Context context);
AddDataFlowToDebugSessionResponseInner addDataFlow(
String resourceGroupName, String factoryName, DataFlowDebugPackage request);

/**
* Deletes a data flow debug session.
*
* @param resourceGroupName The resource group name.
* @param factoryName The factory name.
* @param request Data flow debug session definition for deletion.
* @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)
void delete(String resourceGroupName, String factoryName, DeleteDataFlowDebugSessionRequest request);
Response<Void> deleteWithResponse(
String resourceGroupName, String factoryName, DeleteDataFlowDebugSessionRequest request, Context context);

/**
* Deletes a data flow debug session.
*
* @param resourceGroupName The resource group name.
* @param factoryName The factory name.
* @param request Data flow debug session definition for deletion.
* @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<Void> deleteWithResponse(
String resourceGroupName, String factoryName, DeleteDataFlowDebugSessionRequest request, Context context);
void delete(String resourceGroupName, String factoryName, DeleteDataFlowDebugSessionRequest request);

/**
* Execute a data flow debug command.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,22 +13,6 @@

/** An instance of this class provides access to all the operations defined in DataFlowsClient. */
public interface DataFlowsClient {
/**
* Creates or updates a data flow.
*
* @param resourceGroupName The resource group name.
* @param factoryName The factory name.
* @param dataFlowName The data flow name.
* @param dataFlow Data flow 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 data flow resource type.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
DataFlowResourceInner createOrUpdate(
String resourceGroupName, String factoryName, String dataFlowName, DataFlowResourceInner dataFlow);

/**
* Creates or updates a data flow.
*
Expand All @@ -54,18 +38,20 @@ Response<DataFlowResourceInner> createOrUpdateWithResponse(
Context context);

/**
* Gets a data flow.
* Creates or updates a data flow.
*
* @param resourceGroupName The resource group name.
* @param factoryName The factory name.
* @param dataFlowName The data flow name.
* @param dataFlow Data flow 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 a data flow.
* @return data flow resource type.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
DataFlowResourceInner get(String resourceGroupName, String factoryName, String dataFlowName);
DataFlowResourceInner createOrUpdate(
String resourceGroupName, String factoryName, String dataFlowName, DataFlowResourceInner dataFlow);

/**
* Gets a data flow.
Expand All @@ -86,17 +72,18 @@ Response<DataFlowResourceInner> getWithResponse(
String resourceGroupName, String factoryName, String dataFlowName, String ifNoneMatch, Context context);

/**
* Deletes a data flow.
* Gets a data flow.
*
* @param resourceGroupName The resource group name.
* @param factoryName The factory name.
* @param dataFlowName The data flow 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 data flow.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
void delete(String resourceGroupName, String factoryName, String dataFlowName);
DataFlowResourceInner get(String resourceGroupName, String factoryName, String dataFlowName);

/**
* Deletes a data flow.
Expand All @@ -114,6 +101,19 @@ Response<DataFlowResourceInner> getWithResponse(
Response<Void> deleteWithResponse(
String resourceGroupName, String factoryName, String dataFlowName, Context context);

/**
* Deletes a data flow.
*
* @param resourceGroupName The resource group name.
* @param factoryName The factory name.
* @param dataFlowName The data flow 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 dataFlowName);

/**
* Lists data flows.
*
Expand Down
Loading