diff --git a/sdk/synapse/synapse-artifacts/CHANGELOG.md b/sdk/synapse/synapse-artifacts/CHANGELOG.md index 09122951eb82..bbdec0c45ed5 100644 --- a/sdk/synapse/synapse-artifacts/CHANGELOG.md +++ b/sdk/synapse/synapse-artifacts/CHANGELOG.md @@ -1,21 +1,28 @@ # Release History -## 1.0.0-beta.12 (Unreleased) +## 1.0.0-beta.12 (2023-01-10) ### Features Added -### Breaking Changes +- Added `workspaceResourceId` to AzureSynapseArtifactsLinkedServiceTypeProperties. +- Added `pythonCodeReference`, `filesV2`, `scanFolder`, `configurationType`, `targetSparkConfiguration` and `sparkConfig` properties to SparkJobActivity. +- Added `authHeaders` proprety to RestServiceLinkedService. +- Added new apis of Pause/Resume for Synapse Link. +- Added PowerBIWorkspaceLinkedService. -### Bugs Fixed +### Breaking Changes -### Other Changes +- Renamed API `createOrUpdateLinkConnection` to `createOrUpdate` in `LinkConnectionOperations`. +- Renamed API `deleteLinkConnection` to `delete` in `LinkConnectionOperations`. +- Renamed API `getLinkConnection` to `get` in `LinkConnectionOperations`. +- Renamed API `listLinkConnectionsByWorkspace` to `listByWorkspace` in `LinkConnectionOperations`. ## 1.0.0-beta.11 (2022-09-21) ### Features Added - Updated to `@azure/core-tracing` 1.0. -- add a set of new LinkedService types. +- Added a set of new LinkedService types. ## 1.0.0-beta.10 (2022-04-18) diff --git a/sdk/synapse/synapse-artifacts/review/synapse-artifacts.api.md b/sdk/synapse/synapse-artifacts/review/synapse-artifacts.api.md index ed6ad6b3d575..cc4fb3608f37 100644 --- a/sdk/synapse/synapse-artifacts/review/synapse-artifacts.api.md +++ b/sdk/synapse/synapse-artifacts/review/synapse-artifacts.api.md @@ -1041,6 +1041,7 @@ export interface AzureSynapseArtifactsLinkedService extends LinkedService { authentication?: any; endpoint: any; type: "AzureSynapseArtifacts"; + workspaceResourceId?: any; } // @public @@ -1324,6 +1325,9 @@ export interface ConcurSource extends TabularSource { type: "ConcurSource"; } +// @public +export type ConfigurationType = string; + // @public export interface ControlActivity extends Activity { type: "Container" | "ExecutePipeline" | "IfCondition" | "Switch" | "ForEach" | "Wait" | "Fail" | "Until" | "Validation" | "Filter" | "SetVariable" | "AppendVariable" | "WebHook"; @@ -1856,7 +1860,7 @@ export interface DataFlowSourceSetting { // @public export interface DataFlowStagingInfo { - folderPath?: string; + folderPath?: any; linkedService?: LinkedServiceReference; } @@ -2669,6 +2673,9 @@ export interface FtpServerLocation extends DatasetLocation { type: "FtpServerLocation"; } +// @public +export function getContinuationToken(page: unknown): string | undefined; + // @public export interface GetMetadataActivity extends ExecutionActivity { dataset: DatasetReference; @@ -3522,6 +3529,13 @@ export enum KnownCompressionCodec { ZipDeflate = "zipDeflate" } +// @public +export enum KnownConfigurationType { + Artifact = "Artifact", + Customized = "Customized", + Default = "Default" +} + // @public export enum KnownCopyBehaviorType { FlattenHierarchy = "FlattenHierarchy", @@ -4507,14 +4521,14 @@ export interface LinkConnectionCompute { } // @public -export interface LinkConnectionCreateOrUpdateLinkConnectionOptionalParams extends coreClient.OperationOptions { +export interface LinkConnectionCreateOrUpdateOptionalParams extends coreClient.OperationOptions { } // @public -export type LinkConnectionCreateOrUpdateLinkConnectionResponse = LinkConnectionResource; +export type LinkConnectionCreateOrUpdateResponse = LinkConnectionResource; // @public -export interface LinkConnectionDeleteLinkConnectionOptionalParams extends coreClient.OperationOptions { +export interface LinkConnectionDeleteOptionalParams extends coreClient.OperationOptions { } // @public (undocumented) @@ -4544,11 +4558,11 @@ export interface LinkConnectionGetDetailedStatusOptionalParams extends coreClien export type LinkConnectionGetDetailedStatusResponse = LinkConnectionDetailedStatus; // @public -export interface LinkConnectionGetLinkConnectionOptionalParams extends coreClient.OperationOptions { +export interface LinkConnectionGetOptionalParams extends coreClient.OperationOptions { } // @public -export type LinkConnectionGetLinkConnectionResponse = LinkConnectionResource; +export type LinkConnectionGetResponse = LinkConnectionResource; // @public (undocumented) export interface LinkConnectionLandingZone { @@ -4559,18 +4573,18 @@ export interface LinkConnectionLandingZone { } // @public -export interface LinkConnectionListLinkConnectionsByWorkspaceNextOptionalParams extends coreClient.OperationOptions { +export interface LinkConnectionListByWorkspaceNextOptionalParams extends coreClient.OperationOptions { } // @public -export type LinkConnectionListLinkConnectionsByWorkspaceNextResponse = LinkConnectionListResponse; +export type LinkConnectionListByWorkspaceNextResponse = LinkConnectionListResponse; // @public -export interface LinkConnectionListLinkConnectionsByWorkspaceOptionalParams extends coreClient.OperationOptions { +export interface LinkConnectionListByWorkspaceOptionalParams extends coreClient.OperationOptions { } // @public -export type LinkConnectionListLinkConnectionsByWorkspaceResponse = LinkConnectionListResponse; +export type LinkConnectionListByWorkspaceResponse = LinkConnectionListResponse; // @public export interface LinkConnectionListLinkTablesOptionalParams extends coreClient.OperationOptions { @@ -4587,19 +4601,25 @@ export interface LinkConnectionListResponse { // @public export interface LinkConnectionOperations { - createOrUpdateLinkConnection(linkConnectionName: string, linkConnection: LinkConnectionResource, options?: LinkConnectionCreateOrUpdateLinkConnectionOptionalParams): Promise; - deleteLinkConnection(linkConnectionName: string, options?: LinkConnectionDeleteLinkConnectionOptionalParams): Promise; + createOrUpdate(linkConnectionName: string, linkConnection: LinkConnectionResource, options?: LinkConnectionCreateOrUpdateOptionalParams): Promise; + delete(linkConnectionName: string, options?: LinkConnectionDeleteOptionalParams): Promise; editTables(linkConnectionName: string, editTablesRequest: EditTablesRequest, options?: LinkConnectionEditTablesOptionalParams): Promise; + get(linkConnectionName: string, options?: LinkConnectionGetOptionalParams): Promise; getDetailedStatus(linkConnectionName: string, options?: LinkConnectionGetDetailedStatusOptionalParams): Promise; - getLinkConnection(linkConnectionName: string, options?: LinkConnectionGetLinkConnectionOptionalParams): Promise; - listLinkConnectionsByWorkspace(options?: LinkConnectionListLinkConnectionsByWorkspaceOptionalParams): PagedAsyncIterableIterator; + listByWorkspace(options?: LinkConnectionListByWorkspaceOptionalParams): PagedAsyncIterableIterator; listLinkTables(linkConnectionName: string, options?: LinkConnectionListLinkTablesOptionalParams): Promise; + pause(linkConnectionName: string, options?: LinkConnectionPauseOptionalParams): Promise; queryTableStatus(linkConnectionName: string, queryTableStatusRequest: QueryTableStatusRequest, options?: LinkConnectionQueryTableStatusOptionalParams): Promise; + resume(linkConnectionName: string, options?: LinkConnectionResumeOptionalParams): Promise; start(linkConnectionName: string, options?: LinkConnectionStartOptionalParams): Promise; stop(linkConnectionName: string, options?: LinkConnectionStopOptionalParams): Promise; updateLandingZoneCredential(linkConnectionName: string, updateLandingZoneCredentialRequest: UpdateLandingZoneCredential, options?: LinkConnectionUpdateLandingZoneCredentialOptionalParams): Promise; } +// @public +export interface LinkConnectionPauseOptionalParams extends coreClient.OperationOptions { +} + // @public (undocumented) export interface LinkConnectionQueryTableStatus { continuationToken?: any; @@ -4628,6 +4648,10 @@ export interface LinkConnectionResource { type?: string; } +// @public +export interface LinkConnectionResumeOptionalParams extends coreClient.OperationOptions { +} + // @public (undocumented) export interface LinkConnectionSourceDatabase { linkedService?: LinkedServiceReference; @@ -4693,7 +4717,7 @@ export interface LinkedService { parameters?: { [propertyName: string]: ParameterSpecification; }; - type: "AzureStorage" | "AzureBlobStorage" | "AzureTableStorage" | "AzureSqlDW" | "SqlServer" | "AmazonRdsForSqlServer" | "AzureSqlDatabase" | "AzureSqlMI" | "AzureBatch" | "AzureKeyVault" | "CosmosDb" | "Dynamics" | "DynamicsCrm" | "CommonDataServiceForApps" | "HDInsight" | "FileServer" | "AzureFileStorage" | "GoogleCloudStorage" | "Oracle" | "AmazonRdsForOracle" | "AzureMySql" | "MySql" | "PostgreSql" | "Sybase" | "Db2" | "Teradata" | "AzureML" | "AzureMLService" | "Odbc" | "Informix" | "MicrosoftAccess" | "Hdfs" | "OData" | "Web" | "Cassandra" | "MongoDb" | "MongoDbAtlas" | "MongoDbV2" | "CosmosDbMongoDbApi" | "AzureDataLakeStore" | "AzureBlobFS" | "Office365" | "Salesforce" | "SalesforceServiceCloud" | "SapCloudForCustomer" | "SapEcc" | "SapOpenHub" | "SapOdp" | "RestService" | "TeamDesk" | "Quickbase" | "Smartsheet" | "Zendesk" | "Dataworld" | "AppFigures" | "Asana" | "Twilio" | "GoogleSheets" | "AmazonS3" | "AmazonRedshift" | "CustomDataSource" | "AzureSearch" | "HttpServer" | "FtpServer" | "Sftp" | "SapBW" | "SapHana" | "AmazonMWS" | "AzurePostgreSql" | "Concur" | "Couchbase" | "Drill" | "Eloqua" | "GoogleBigQuery" | "Greenplum" | "HBase" | "Hive" | "Hubspot" | "Impala" | "Jira" | "Magento" | "MariaDB" | "AzureMariaDB" | "Marketo" | "Paypal" | "Phoenix" | "Presto" | "QuickBooks" | "ServiceNow" | "Shopify" | "Spark" | "Square" | "Xero" | "Zoho" | "Vertica" | "Netezza" | "SalesforceMarketingCloud" | "HDInsightOnDemand" | "AzureDataLakeAnalytics" | "AzureDatabricks" | "AzureDatabricksDeltaLake" | "Responsys" | "DynamicsAX" | "OracleServiceCloud" | "GoogleAdWords" | "SapTable" | "AzureDataExplorer" | "AzureFunction" | "Snowflake" | "SharePointOnlineList" | "AzureSynapseArtifacts"; + type: "AzureStorage" | "AzureBlobStorage" | "AzureTableStorage" | "AzureSqlDW" | "SqlServer" | "AmazonRdsForSqlServer" | "AzureSqlDatabase" | "AzureSqlMI" | "AzureBatch" | "AzureKeyVault" | "CosmosDb" | "Dynamics" | "DynamicsCrm" | "CommonDataServiceForApps" | "HDInsight" | "FileServer" | "AzureFileStorage" | "GoogleCloudStorage" | "Oracle" | "AmazonRdsForOracle" | "AzureMySql" | "MySql" | "PostgreSql" | "Sybase" | "Db2" | "Teradata" | "AzureML" | "AzureMLService" | "Odbc" | "Informix" | "MicrosoftAccess" | "Hdfs" | "OData" | "Web" | "Cassandra" | "MongoDb" | "MongoDbAtlas" | "MongoDbV2" | "CosmosDbMongoDbApi" | "AzureDataLakeStore" | "AzureBlobFS" | "Office365" | "Salesforce" | "SalesforceServiceCloud" | "SapCloudForCustomer" | "SapEcc" | "SapOpenHub" | "SapOdp" | "RestService" | "TeamDesk" | "Quickbase" | "Smartsheet" | "Zendesk" | "Dataworld" | "AppFigures" | "Asana" | "Twilio" | "GoogleSheets" | "AmazonS3" | "AmazonRedshift" | "CustomDataSource" | "AzureSearch" | "HttpServer" | "FtpServer" | "Sftp" | "SapBW" | "SapHana" | "AmazonMWS" | "AzurePostgreSql" | "Concur" | "Couchbase" | "Drill" | "Eloqua" | "GoogleBigQuery" | "Greenplum" | "HBase" | "Hive" | "Hubspot" | "Impala" | "Jira" | "Magento" | "MariaDB" | "AzureMariaDB" | "Marketo" | "Paypal" | "Phoenix" | "Presto" | "QuickBooks" | "ServiceNow" | "Shopify" | "Spark" | "Square" | "Xero" | "Zoho" | "Vertica" | "Netezza" | "SalesforceMarketingCloud" | "HDInsightOnDemand" | "AzureDataLakeAnalytics" | "AzureDatabricks" | "AzureDatabricksDeltaLake" | "Responsys" | "DynamicsAX" | "OracleServiceCloud" | "GoogleAdWords" | "SapTable" | "AzureDataExplorer" | "AzureFunction" | "Snowflake" | "SharePointOnlineList" | "AzureSynapseArtifacts" | "PowerBIWorkspace"; } // @public @@ -4778,7 +4802,7 @@ export interface LinkedServiceResource extends SubResource { } // @public (undocumented) -export type LinkedServiceUnion = LinkedService | AzureStorageLinkedService | AzureBlobStorageLinkedService | AzureTableStorageLinkedService | AzureSqlDWLinkedService | SqlServerLinkedService | AmazonRdsForSqlServerLinkedService | AzureSqlDatabaseLinkedService | AzureSqlMILinkedService | AzureBatchLinkedService | AzureKeyVaultLinkedService | CosmosDbLinkedService | DynamicsLinkedService | DynamicsCrmLinkedService | CommonDataServiceForAppsLinkedService | HDInsightLinkedService | FileServerLinkedService | AzureFileStorageLinkedService | GoogleCloudStorageLinkedService | OracleLinkedService | AmazonRdsForOracleLinkedService | AzureMySqlLinkedService | MySqlLinkedService | PostgreSqlLinkedService | SybaseLinkedService | Db2LinkedService | TeradataLinkedService | AzureMLLinkedService | AzureMLServiceLinkedService | OdbcLinkedService | InformixLinkedService | MicrosoftAccessLinkedService | HdfsLinkedService | ODataLinkedService | WebLinkedService | CassandraLinkedService | MongoDbLinkedService | MongoDbAtlasLinkedService | MongoDbV2LinkedService | CosmosDbMongoDbApiLinkedService | AzureDataLakeStoreLinkedService | AzureBlobFSLinkedService | Office365LinkedService | SalesforceLinkedService | SalesforceServiceCloudLinkedService | SapCloudForCustomerLinkedService | SapEccLinkedService | SapOpenHubLinkedService | SapOdpLinkedService | RestServiceLinkedService | TeamDeskLinkedService | QuickbaseLinkedService | SmartsheetLinkedService | ZendeskLinkedService | DataworldLinkedService | AppFiguresLinkedService | AsanaLinkedService | TwilioLinkedService | GoogleSheetsLinkedService | AmazonS3LinkedService | AmazonRedshiftLinkedService | CustomDataSourceLinkedService | AzureSearchLinkedService | HttpLinkedService | FtpServerLinkedService | SftpServerLinkedService | SapBWLinkedService | SapHanaLinkedService | AmazonMWSLinkedService | AzurePostgreSqlLinkedService | ConcurLinkedService | CouchbaseLinkedService | DrillLinkedService | EloquaLinkedService | GoogleBigQueryLinkedService | GreenplumLinkedService | HBaseLinkedService | HiveLinkedService | HubspotLinkedService | ImpalaLinkedService | JiraLinkedService | MagentoLinkedService | MariaDBLinkedService | AzureMariaDBLinkedService | MarketoLinkedService | PaypalLinkedService | PhoenixLinkedService | PrestoLinkedService | QuickBooksLinkedService | ServiceNowLinkedService | ShopifyLinkedService | SparkLinkedService | SquareLinkedService | XeroLinkedService | ZohoLinkedService | VerticaLinkedService | NetezzaLinkedService | SalesforceMarketingCloudLinkedService | HDInsightOnDemandLinkedService | AzureDataLakeAnalyticsLinkedService | AzureDatabricksLinkedService | AzureDatabricksDeltaLakeLinkedService | ResponsysLinkedService | DynamicsAXLinkedService | OracleServiceCloudLinkedService | GoogleAdWordsLinkedService | SapTableLinkedService | AzureDataExplorerLinkedService | AzureFunctionLinkedService | SnowflakeLinkedService | SharePointOnlineListLinkedService | AzureSynapseArtifactsLinkedService; +export type LinkedServiceUnion = LinkedService | AzureStorageLinkedService | AzureBlobStorageLinkedService | AzureTableStorageLinkedService | AzureSqlDWLinkedService | SqlServerLinkedService | AmazonRdsForSqlServerLinkedService | AzureSqlDatabaseLinkedService | AzureSqlMILinkedService | AzureBatchLinkedService | AzureKeyVaultLinkedService | CosmosDbLinkedService | DynamicsLinkedService | DynamicsCrmLinkedService | CommonDataServiceForAppsLinkedService | HDInsightLinkedService | FileServerLinkedService | AzureFileStorageLinkedService | GoogleCloudStorageLinkedService | OracleLinkedService | AmazonRdsForOracleLinkedService | AzureMySqlLinkedService | MySqlLinkedService | PostgreSqlLinkedService | SybaseLinkedService | Db2LinkedService | TeradataLinkedService | AzureMLLinkedService | AzureMLServiceLinkedService | OdbcLinkedService | InformixLinkedService | MicrosoftAccessLinkedService | HdfsLinkedService | ODataLinkedService | WebLinkedService | CassandraLinkedService | MongoDbLinkedService | MongoDbAtlasLinkedService | MongoDbV2LinkedService | CosmosDbMongoDbApiLinkedService | AzureDataLakeStoreLinkedService | AzureBlobFSLinkedService | Office365LinkedService | SalesforceLinkedService | SalesforceServiceCloudLinkedService | SapCloudForCustomerLinkedService | SapEccLinkedService | SapOpenHubLinkedService | SapOdpLinkedService | RestServiceLinkedService | TeamDeskLinkedService | QuickbaseLinkedService | SmartsheetLinkedService | ZendeskLinkedService | DataworldLinkedService | AppFiguresLinkedService | AsanaLinkedService | TwilioLinkedService | GoogleSheetsLinkedService | AmazonS3LinkedService | AmazonRedshiftLinkedService | CustomDataSourceLinkedService | AzureSearchLinkedService | HttpLinkedService | FtpServerLinkedService | SftpServerLinkedService | SapBWLinkedService | SapHanaLinkedService | AmazonMWSLinkedService | AzurePostgreSqlLinkedService | ConcurLinkedService | CouchbaseLinkedService | DrillLinkedService | EloquaLinkedService | GoogleBigQueryLinkedService | GreenplumLinkedService | HBaseLinkedService | HiveLinkedService | HubspotLinkedService | ImpalaLinkedService | JiraLinkedService | MagentoLinkedService | MariaDBLinkedService | AzureMariaDBLinkedService | MarketoLinkedService | PaypalLinkedService | PhoenixLinkedService | PrestoLinkedService | QuickBooksLinkedService | ServiceNowLinkedService | ShopifyLinkedService | SparkLinkedService | SquareLinkedService | XeroLinkedService | ZohoLinkedService | VerticaLinkedService | NetezzaLinkedService | SalesforceMarketingCloudLinkedService | HDInsightOnDemandLinkedService | AzureDataLakeAnalyticsLinkedService | AzureDatabricksLinkedService | AzureDatabricksDeltaLakeLinkedService | ResponsysLinkedService | DynamicsAXLinkedService | OracleServiceCloudLinkedService | GoogleAdWordsLinkedService | SapTableLinkedService | AzureDataExplorerLinkedService | AzureFunctionLinkedService | SnowflakeLinkedService | SharePointOnlineListLinkedService | AzureSynapseArtifactsLinkedService | PowerBIWorkspaceLinkedService; // @public (undocumented) export interface LinkTableListResponse { @@ -5920,6 +5944,13 @@ export interface PostgreSqlTableDataset extends Dataset { type: "PostgreSqlTable"; } +// @public +export interface PowerBIWorkspaceLinkedService extends LinkedService { + tenantId: string; + type: "PowerBIWorkspace"; + workspaceId: string; +} + // @public export type PrestoAuthenticationType = string; @@ -6160,6 +6191,7 @@ export type RestServiceAuthenticationType = string; export interface RestServiceLinkedService extends LinkedService { aadResourceId?: any; authenticationType: RestServiceAuthenticationType; + authHeaders?: any; azureCloudType?: any; clientId?: any; clientSecret?: SecretBaseUnion; @@ -6864,7 +6896,7 @@ export interface SnowflakeSink extends CopySink { // @public export interface SnowflakeSource extends CopySource { - exportSettings?: SnowflakeExportCopyCommand; + exportSettings: SnowflakeExportCopyCommand; query?: any; type: "SnowflakeSource"; } @@ -6987,6 +7019,12 @@ export interface SparkConfigurationOperations { listSparkConfigurationsByWorkspace(options?: SparkConfigurationGetSparkConfigurationsByWorkspaceOptionalParams): PagedAsyncIterableIterator; } +// @public +export interface SparkConfigurationParametrizationReference { + referenceName: any; + type: SparkConfigurationReferenceType; +} + // @public export interface SparkConfigurationReference { referenceName: string; @@ -7784,13 +7822,21 @@ export interface SynapseSparkJobDefinitionActivity extends ExecutionActivity { arguments?: any[]; className?: any; conf?: any; + configurationType?: ConfigurationType; driverSize?: any; executorSize?: any; file?: any; files?: any[]; - numExecutors?: number; + filesV2?: any[]; + numExecutors?: any; + pythonCodeReference?: any[]; + scanFolder?: any; + sparkConfig?: { + [propertyName: string]: any; + }; sparkJob: SynapseSparkJobReference; targetBigDataPool?: BigDataPoolParametrizationReference; + targetSparkConfiguration?: SparkConfigurationParametrizationReference; type: "SparkJob"; } diff --git a/sdk/synapse/synapse-artifacts/src/artifactsClient.ts b/sdk/synapse/synapse-artifacts/src/artifactsClient.ts index a7941a953f8d..caf14ca5a6e0 100644 --- a/sdk/synapse/synapse-artifacts/src/artifactsClient.ts +++ b/sdk/synapse/synapse-artifacts/src/artifactsClient.ts @@ -107,31 +107,40 @@ export class ArtifactsClient extends coreClient.ServiceClient { userAgentOptions: { userAgentPrefix }, - baseUri: options.endpoint ?? options.baseUri ?? "{endpoint}" + endpoint: options.endpoint ?? options.baseUri ?? "{endpoint}" }; super(optionsWithDefaults); + let bearerTokenAuthenticationPolicyFound: boolean = false; if (options?.pipeline && options.pipeline.getOrderedPolicies().length > 0) { const pipelinePolicies: coreRestPipeline.PipelinePolicy[] = options.pipeline.getOrderedPolicies(); - const bearerTokenAuthenticationPolicyFound = pipelinePolicies.some( + bearerTokenAuthenticationPolicyFound = pipelinePolicies.some( (pipelinePolicy) => pipelinePolicy.name === coreRestPipeline.bearerTokenAuthenticationPolicyName ); - if (!bearerTokenAuthenticationPolicyFound) { - this.pipeline.removePolicy({ - name: coreRestPipeline.bearerTokenAuthenticationPolicyName - }); - this.pipeline.addPolicy( - coreRestPipeline.bearerTokenAuthenticationPolicy({ - scopes: `${optionsWithDefaults.baseUri}/.default`, - challengeCallbacks: { - authorizeRequestOnChallenge: - coreClient.authorizeRequestOnClaimChallenge - } - }) - ); - } + } + if ( + !options || + !options.pipeline || + options.pipeline.getOrderedPolicies().length == 0 || + !bearerTokenAuthenticationPolicyFound + ) { + this.pipeline.removePolicy({ + name: coreRestPipeline.bearerTokenAuthenticationPolicyName + }); + this.pipeline.addPolicy( + coreRestPipeline.bearerTokenAuthenticationPolicy({ + credential: credentials, + scopes: + optionsWithDefaults.credentialScopes ?? + `${optionsWithDefaults.endpoint}/.default`, + challengeCallbacks: { + authorizeRequestOnChallenge: + coreClient.authorizeRequestOnClaimChallenge + } + }) + ); } // Parameter assignments this.endpoint = endpoint; diff --git a/sdk/synapse/synapse-artifacts/src/index.ts b/sdk/synapse/synapse-artifacts/src/index.ts index 413a8d7eccaa..920f85335c80 100644 --- a/sdk/synapse/synapse-artifacts/src/index.ts +++ b/sdk/synapse/synapse-artifacts/src/index.ts @@ -7,6 +7,7 @@ */ /// +export { getContinuationToken } from "./pagingHelper"; export * from "./models"; export { ArtifactsClient } from "./artifactsClient"; export * from "./operationsInterfaces"; diff --git a/sdk/synapse/synapse-artifacts/src/models/index.ts b/sdk/synapse/synapse-artifacts/src/models/index.ts index b48d7c2793e7..00c47a9645d3 100644 --- a/sdk/synapse/synapse-artifacts/src/models/index.ts +++ b/sdk/synapse/synapse-artifacts/src/models/index.ts @@ -227,7 +227,8 @@ export type LinkedServiceUnion = | AzureFunctionLinkedService | SnowflakeLinkedService | SharePointOnlineListLinkedService - | AzureSynapseArtifactsLinkedService; + | AzureSynapseArtifactsLinkedService + | PowerBIWorkspaceLinkedService; export type ActivityUnion = | Activity | ControlActivityUnion @@ -677,7 +678,7 @@ export interface LinkConnectionDetailedStatus { startTime?: any; /** Link connection stop time */ stopTime?: any; - /** Link connection status */ + /** Link connection status, please refer to this [articles](https://learn.microsoft.com/azure/synapse-analytics/synapse-link/sql-database-synapse-link#monitoring) for details. */ status?: string; /** Link connection's corresponding continuous run id */ continuousRunId?: string; @@ -735,7 +736,7 @@ export interface LinkConnectionQueryTableStatus { export interface LinkTableStatus { /** ID provided by the client */ id?: string; - /** Link table status */ + /** Link table status, please refer to this [articles](https://learn.microsoft.com/azure/synapse-analytics/synapse-link/sql-database-synapse-link#monitoring) for details. */ status?: string; /** Link table error message */ errorMessage?: string; @@ -1344,7 +1345,8 @@ export interface LinkedService { | "AzureFunction" | "Snowflake" | "SharePointOnlineList" - | "AzureSynapseArtifacts"; + | "AzureSynapseArtifacts" + | "PowerBIWorkspace"; /** Describes unknown properties. The value of an unknown property can be of "any" type. */ [property: string]: any; /** The integration runtime reference. */ @@ -1372,7 +1374,7 @@ export interface DataFlowStagingInfo { /** Staging linked service reference. */ linkedService?: LinkedServiceReference; /** Folder path for staging blob. */ - folderPath?: string; + folderPath?: any; } /** Data flow debug settings. */ @@ -3588,6 +3590,14 @@ export interface ScriptActivityTypePropertiesLogSettings { logLocationSettings?: LogLocationSettings; } +/** Spark configuration reference. */ +export interface SparkConfigurationParametrizationReference { + /** Spark configuration reference type. */ + type: SparkConfigurationReferenceType; + /** Reference spark configuration name. Type: string (or Expression with resultType string). */ + referenceName: any; +} + /** The workflow trigger recurrence. */ export interface ScheduleTriggerRecurrence { /** Describes unknown properties. The value of an unknown property can be of "any" type. */ @@ -5806,6 +5816,8 @@ export interface RestServiceLinkedService extends LinkedService { userName?: any; /** The password used in Basic authentication type. */ password?: SecretBaseUnion; + /** The additional HTTP headers in the request to RESTful API used for authorization. Type: object (or Expression with resultType object). */ + authHeaders?: any; /** The application's client ID used in AadServicePrincipal authentication type. */ servicePrincipalId?: any; /** The application's key used in AadServicePrincipal authentication type. */ @@ -7091,6 +7103,18 @@ export interface AzureSynapseArtifactsLinkedService extends LinkedService { endpoint: any; /** Required to specify MSI, if using system assigned managed identity as authentication method. Type: string (or Expression with resultType string). */ authentication?: any; + /** The resource ID of the Synapse workspace. The format should be: /subscriptions/{subscriptionID}/resourceGroups/{resourceGroup}/providers/Microsoft.Synapse/workspaces/{workspaceName}. Type: string (or Expression with resultType string). */ + workspaceResourceId?: any; +} + +/** Power BI Workspace linked service. */ +export interface PowerBIWorkspaceLinkedService extends LinkedService { + /** Polymorphic discriminator, which specifies the different types this object can be */ + type: "PowerBIWorkspace"; + /** The Power BI workspace id. */ + workspaceId: string; + /** The tenant id to which the Power BI workspace belongs. */ + tenantId: string; } /** Base class for all control activities like IfCondition, ForEach , Until. */ @@ -8327,7 +8351,7 @@ export interface SnowflakeSource extends CopySource { /** Snowflake Sql query. Type: string (or Expression with resultType string). */ query?: any; /** Snowflake export settings. */ - exportSettings?: SnowflakeExportCopyCommand; + exportSettings: SnowflakeExportCopyCommand; } /** A copy activity Azure Databricks Delta Lake source. */ @@ -9620,10 +9644,16 @@ export interface SynapseSparkJobDefinitionActivity extends ExecutionActivity { arguments?: any[]; /** The main file used for the job, which will override the 'file' of the spark job definition you provide. Type: string (or Expression with resultType string). */ file?: any; + /** Scanning subfolders from the root folder of the main definition file, these files will be added as reference files. The folders named 'jars', 'pyFiles', 'files' or 'archives' will be scanned, and the folders name are case sensitive. Type: boolean (or Expression with resultType boolean). */ + scanFolder?: any; /** The fully-qualified identifier or the main class that is in the main definition file, which will override the 'className' of the spark job definition you provide. Type: string (or Expression with resultType string). */ className?: any; - /** Additional files used for reference in the main definition file, which will override the 'files' of the spark job definition you provide. */ + /** (Deprecated. Please use pythonCodeReference and filesV2) Additional files used for reference in the main definition file, which will override the 'files' of the spark job definition you provide. */ files?: any[]; + /** Additional python code files used for reference in the main definition file, which will override the 'pyFiles' of the spark job definition you provide. */ + pythonCodeReference?: any[]; + /** Additional files used for reference in the main definition file, which will override the 'jars' and 'files' of the spark job definition you provide. */ + filesV2?: any[]; /** The name of the big data pool which will be used to execute the spark batch job, which will override the 'targetBigDataPool' of the spark job definition you provide. */ targetBigDataPool?: BigDataPoolParametrizationReference; /** Number of core and memory to be used for executors allocated in the specified Spark pool for the job, which will be used for overriding 'executorCores' and 'executorMemory' of the spark job definition you provide. Type: string (or Expression with resultType string). */ @@ -9632,8 +9662,14 @@ export interface SynapseSparkJobDefinitionActivity extends ExecutionActivity { conf?: any; /** Number of core and memory to be used for driver allocated in the specified Spark pool for the job, which will be used for overriding 'driverCores' and 'driverMemory' of the spark job definition you provide. Type: string (or Expression with resultType string). */ driverSize?: any; - /** Number of executors to launch for this job, which will override the 'numExecutors' of the spark job definition you provide. */ - numExecutors?: number; + /** Number of executors to launch for this job, which will override the 'numExecutors' of the spark job definition you provide. Type: integer (or Expression with resultType integer). */ + numExecutors?: any; + /** The type of the spark config. */ + configurationType?: ConfigurationType; + /** The spark configuration of the spark job. */ + targetSparkConfiguration?: SparkConfigurationParametrizationReference; + /** Spark configuration property. */ + sparkConfig?: { [propertyName: string]: any }; } /** Trigger that creates pipeline runs periodically, on schedule. */ @@ -12322,6 +12358,27 @@ export enum KnownScriptActivityLogDestination { */ export type ScriptActivityLogDestination = string; +/** Known values of {@link ConfigurationType} that the service accepts. */ +export enum KnownConfigurationType { + /** Default */ + Default = "Default", + /** Customized */ + Customized = "Customized", + /** Artifact */ + Artifact = "Artifact" +} + +/** + * Defines values for ConfigurationType. \ + * {@link KnownConfigurationType} can be used interchangeably with ConfigurationType, + * this enum contains the known values that the service supports. + * ### Known values supported by the service + * **Default** \ + * **Customized** \ + * **Artifact** + */ +export type ConfigurationType = string; + /** Known values of {@link RecurrenceFrequency} that the service accepts. */ export enum KnownRecurrenceFrequency { /** NotSpecified */ @@ -12853,28 +12910,28 @@ export type DayOfWeek = | "Saturday"; /** Optional parameters. */ -export interface LinkConnectionListLinkConnectionsByWorkspaceOptionalParams +export interface LinkConnectionListByWorkspaceOptionalParams extends coreClient.OperationOptions {} -/** Contains response data for the listLinkConnectionsByWorkspace operation. */ -export type LinkConnectionListLinkConnectionsByWorkspaceResponse = LinkConnectionListResponse; +/** Contains response data for the listByWorkspace operation. */ +export type LinkConnectionListByWorkspaceResponse = LinkConnectionListResponse; /** Optional parameters. */ -export interface LinkConnectionCreateOrUpdateLinkConnectionOptionalParams +export interface LinkConnectionCreateOrUpdateOptionalParams extends coreClient.OperationOptions {} -/** Contains response data for the createOrUpdateLinkConnection operation. */ -export type LinkConnectionCreateOrUpdateLinkConnectionResponse = LinkConnectionResource; +/** Contains response data for the createOrUpdate operation. */ +export type LinkConnectionCreateOrUpdateResponse = LinkConnectionResource; /** Optional parameters. */ -export interface LinkConnectionGetLinkConnectionOptionalParams +export interface LinkConnectionGetOptionalParams extends coreClient.OperationOptions {} -/** Contains response data for the getLinkConnection operation. */ -export type LinkConnectionGetLinkConnectionResponse = LinkConnectionResource; +/** Contains response data for the get operation. */ +export type LinkConnectionGetResponse = LinkConnectionResource; /** Optional parameters. */ -export interface LinkConnectionDeleteLinkConnectionOptionalParams +export interface LinkConnectionDeleteOptionalParams extends coreClient.OperationOptions {} /** Optional parameters. */ @@ -12915,11 +12972,19 @@ export interface LinkConnectionUpdateLandingZoneCredentialOptionalParams extends coreClient.OperationOptions {} /** Optional parameters. */ -export interface LinkConnectionListLinkConnectionsByWorkspaceNextOptionalParams +export interface LinkConnectionPauseOptionalParams + extends coreClient.OperationOptions {} + +/** Optional parameters. */ +export interface LinkConnectionResumeOptionalParams + extends coreClient.OperationOptions {} + +/** Optional parameters. */ +export interface LinkConnectionListByWorkspaceNextOptionalParams extends coreClient.OperationOptions {} -/** Contains response data for the listLinkConnectionsByWorkspaceNext operation. */ -export type LinkConnectionListLinkConnectionsByWorkspaceNextResponse = LinkConnectionListResponse; +/** Contains response data for the listByWorkspaceNext operation. */ +export type LinkConnectionListByWorkspaceNextResponse = LinkConnectionListResponse; /** Optional parameters. */ export interface KqlScriptsGetAllOptionalParams diff --git a/sdk/synapse/synapse-artifacts/src/models/mappers.ts b/sdk/synapse/synapse-artifacts/src/models/mappers.ts index 0c68cd147d1c..92c971240c40 100644 --- a/sdk/synapse/synapse-artifacts/src/models/mappers.ts +++ b/sdk/synapse/synapse-artifacts/src/models/mappers.ts @@ -1984,7 +1984,7 @@ export const DataFlowStagingInfo: coreClient.CompositeMapper = { folderPath: { serializedName: "folderPath", type: { - name: "String" + name: "any" } } } @@ -7387,6 +7387,29 @@ export const ScriptActivityTypePropertiesLogSettings: coreClient.CompositeMapper } }; +export const SparkConfigurationParametrizationReference: coreClient.CompositeMapper = { + type: { + name: "Composite", + className: "SparkConfigurationParametrizationReference", + modelProperties: { + type: { + serializedName: "type", + required: true, + type: { + name: "String" + } + }, + referenceName: { + serializedName: "referenceName", + required: true, + type: { + name: "any" + } + } + } + } +}; + export const ScheduleTriggerRecurrence: coreClient.CompositeMapper = { type: { name: "Composite", @@ -13634,6 +13657,12 @@ export const RestServiceLinkedService: coreClient.CompositeMapper = { className: "SecretBase" } }, + authHeaders: { + serializedName: "typeProperties.authHeaders", + type: { + name: "any" + } + }, servicePrincipalId: { serializedName: "typeProperties.servicePrincipalId", type: { @@ -17417,6 +17446,40 @@ export const AzureSynapseArtifactsLinkedService: coreClient.CompositeMapper = { type: { name: "any" } + }, + workspaceResourceId: { + serializedName: "typeProperties.workspaceResourceId", + type: { + name: "any" + } + } + } + } +}; + +export const PowerBIWorkspaceLinkedService: coreClient.CompositeMapper = { + serializedName: "PowerBIWorkspace", + type: { + name: "Composite", + className: "PowerBIWorkspaceLinkedService", + uberParent: "LinkedService", + additionalProperties: { type: { name: "Object" } }, + polymorphicDiscriminator: LinkedService.type.polymorphicDiscriminator, + modelProperties: { + ...LinkedService.type.modelProperties, + workspaceId: { + serializedName: "typeProperties.workspaceId", + required: true, + type: { + name: "String" + } + }, + tenantId: { + serializedName: "typeProperties.tenantId", + required: true, + type: { + name: "String" + } } } } @@ -22348,9 +22411,9 @@ export const ExecutePipelineActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "ExecutePipelineActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, pipeline: { @@ -22382,9 +22445,9 @@ export const IfConditionActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "IfConditionActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, expression: { @@ -22427,9 +22490,9 @@ export const SwitchActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "SwitchActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, on: { @@ -22472,9 +22535,9 @@ export const ForEachActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "ForEachActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, isSequential: { @@ -22521,9 +22584,9 @@ export const WaitActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "WaitActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, waitTimeInSeconds: { @@ -22542,9 +22605,9 @@ export const FailActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "FailActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, message: { @@ -22570,9 +22633,9 @@ export const UntilActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "UntilActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, expression: { @@ -22610,9 +22673,9 @@ export const ValidationActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "ValidationActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, timeout: { @@ -22655,9 +22718,9 @@ export const FilterActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "FilterActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, items: { @@ -22683,9 +22746,9 @@ export const SetVariableActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "SetVariableActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, variableName: { @@ -22709,9 +22772,9 @@ export const AppendVariableActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "AppendVariableActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, variableName: { @@ -22735,9 +22798,9 @@ export const WebHookActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "WebHookActivity", - uberParent: "Activity", + uberParent: "ControlActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ControlActivity.type.polymorphicDiscriminator, modelProperties: { ...ControlActivity.type.modelProperties, method: { @@ -22794,9 +22857,9 @@ export const CopyActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "CopyActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, inputs: { @@ -22939,9 +23002,9 @@ export const HDInsightHiveActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "HDInsightHiveActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, storageLinkedServices: { @@ -23019,9 +23082,9 @@ export const HDInsightPigActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "HDInsightPigActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, storageLinkedServices: { @@ -23077,9 +23140,9 @@ export const HDInsightMapReduceActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "HDInsightMapReduceActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, storageLinkedServices: { @@ -23159,9 +23222,9 @@ export const HDInsightStreamingActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "HDInsightStreamingActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, storageLinkedServices: { @@ -23273,9 +23336,9 @@ export const HDInsightSparkActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "HDInsightSparkActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, rootPath: { @@ -23344,9 +23407,9 @@ export const ExecuteSsisPackageActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "ExecuteSsisPackageActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, packageLocation: { @@ -23459,9 +23522,9 @@ export const CustomActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "CustomActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, command: { @@ -23519,9 +23582,9 @@ export const SqlServerStoredProcedureActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "SqlServerStoredProcedureActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, storedProcedureName: { @@ -23546,9 +23609,9 @@ export const DeleteActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "DeleteActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, recursive: { @@ -23602,9 +23665,9 @@ export const AzureDataExplorerCommandActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "AzureDataExplorerCommandActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, command: { @@ -23629,9 +23692,9 @@ export const LookupActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "LookupActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, source: { @@ -23663,9 +23726,9 @@ export const WebActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "WebActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, method: { @@ -23741,9 +23804,9 @@ export const GetMetadataActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "GetMetadataActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, dataset: { @@ -23787,9 +23850,9 @@ export const AzureMLBatchExecutionActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "AzureMLBatchExecutionActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, globalParameters: { @@ -23826,9 +23889,9 @@ export const AzureMLUpdateResourceActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "AzureMLUpdateResourceActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, trainedModelName: { @@ -23861,9 +23924,9 @@ export const AzureMLExecutePipelineActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "AzureMLExecutePipelineActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, mlPipelineId: { @@ -23906,9 +23969,9 @@ export const DataLakeAnalyticsUsqlActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "DataLakeAnalyticsUsqlActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, scriptPath: { @@ -23965,9 +24028,9 @@ export const DatabricksNotebookActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "DatabricksNotebookActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, notebookPath: { @@ -24005,9 +24068,9 @@ export const DatabricksSparkJarActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "DatabricksSparkJarActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, mainClassName: { @@ -24049,9 +24112,9 @@ export const DatabricksSparkPythonActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "DatabricksSparkPythonActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, pythonFile: { @@ -24093,9 +24156,9 @@ export const AzureFunctionActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "AzureFunctionActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, method: { @@ -24133,9 +24196,9 @@ export const ExecuteDataFlowActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "ExecuteDataFlowActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, dataflow: { @@ -24199,9 +24262,9 @@ export const ScriptActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "ScriptActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, scripts: { @@ -24232,9 +24295,9 @@ export const SynapseNotebookActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "SynapseNotebookActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, notebook: { @@ -24291,9 +24354,9 @@ export const SynapseSparkJobDefinitionActivity: coreClient.CompositeMapper = { type: { name: "Composite", className: "SynapseSparkJobDefinitionActivity", - uberParent: "Activity", + uberParent: "ExecutionActivity", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Activity.type.polymorphicDiscriminator, + polymorphicDiscriminator: ExecutionActivity.type.polymorphicDiscriminator, modelProperties: { ...ExecutionActivity.type.modelProperties, sparkJob: { @@ -24320,6 +24383,12 @@ export const SynapseSparkJobDefinitionActivity: coreClient.CompositeMapper = { name: "any" } }, + scanFolder: { + serializedName: "typeProperties.scanFolder", + type: { + name: "any" + } + }, className: { serializedName: "typeProperties.className", type: { @@ -24337,6 +24406,28 @@ export const SynapseSparkJobDefinitionActivity: coreClient.CompositeMapper = { } } }, + pythonCodeReference: { + serializedName: "typeProperties.pythonCodeReference", + type: { + name: "Sequence", + element: { + type: { + name: "any" + } + } + } + }, + filesV2: { + serializedName: "typeProperties.filesV2", + type: { + name: "Sequence", + element: { + type: { + name: "any" + } + } + } + }, targetBigDataPool: { serializedName: "typeProperties.targetBigDataPool", type: { @@ -24365,7 +24456,27 @@ export const SynapseSparkJobDefinitionActivity: coreClient.CompositeMapper = { numExecutors: { serializedName: "typeProperties.numExecutors", type: { - name: "Number" + name: "any" + } + }, + configurationType: { + serializedName: "typeProperties.configurationType", + type: { + name: "String" + } + }, + targetSparkConfiguration: { + serializedName: "typeProperties.targetSparkConfiguration", + type: { + name: "Composite", + className: "SparkConfigurationParametrizationReference" + } + }, + sparkConfig: { + serializedName: "typeProperties.sparkConfig", + type: { + name: "Dictionary", + value: { type: { name: "any" } } } } } @@ -24377,9 +24488,10 @@ export const ScheduleTrigger: coreClient.CompositeMapper = { type: { name: "Composite", className: "ScheduleTrigger", - uberParent: "Trigger", + uberParent: "MultiplePipelineTrigger", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Trigger.type.polymorphicDiscriminator, + polymorphicDiscriminator: + MultiplePipelineTrigger.type.polymorphicDiscriminator, modelProperties: { ...MultiplePipelineTrigger.type.modelProperties, recurrence: { @@ -24398,9 +24510,10 @@ export const BlobTrigger: coreClient.CompositeMapper = { type: { name: "Composite", className: "BlobTrigger", - uberParent: "Trigger", + uberParent: "MultiplePipelineTrigger", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Trigger.type.polymorphicDiscriminator, + polymorphicDiscriminator: + MultiplePipelineTrigger.type.polymorphicDiscriminator, modelProperties: { ...MultiplePipelineTrigger.type.modelProperties, folderPath: { @@ -24433,9 +24546,10 @@ export const BlobEventsTrigger: coreClient.CompositeMapper = { type: { name: "Composite", className: "BlobEventsTrigger", - uberParent: "Trigger", + uberParent: "MultiplePipelineTrigger", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Trigger.type.polymorphicDiscriminator, + polymorphicDiscriminator: + MultiplePipelineTrigger.type.polymorphicDiscriminator, modelProperties: { ...MultiplePipelineTrigger.type.modelProperties, blobPathBeginsWith: { @@ -24484,9 +24598,10 @@ export const CustomEventsTrigger: coreClient.CompositeMapper = { type: { name: "Composite", className: "CustomEventsTrigger", - uberParent: "Trigger", + uberParent: "MultiplePipelineTrigger", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: Trigger.type.polymorphicDiscriminator, + polymorphicDiscriminator: + MultiplePipelineTrigger.type.polymorphicDiscriminator, modelProperties: { ...MultiplePipelineTrigger.type.modelProperties, subjectBeginsWith: { @@ -24529,9 +24644,9 @@ export const AzureTableSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "AzureTableSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, azureTableSourceQuery: { @@ -24555,9 +24670,9 @@ export const InformixSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "InformixSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24575,9 +24690,9 @@ export const Db2Source: coreClient.CompositeMapper = { type: { name: "Composite", className: "Db2Source", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24595,9 +24710,9 @@ export const OdbcSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "OdbcSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24615,9 +24730,9 @@ export const MySqlSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "MySqlSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24635,9 +24750,9 @@ export const PostgreSqlSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "PostgreSqlSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24655,9 +24770,9 @@ export const SybaseSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SybaseSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24675,9 +24790,9 @@ export const SapBwSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SapBwSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24695,9 +24810,9 @@ export const SalesforceSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SalesforceSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24721,9 +24836,9 @@ export const SapCloudForCustomerSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SapCloudForCustomerSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24747,9 +24862,9 @@ export const SapEccSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SapEccSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24773,9 +24888,9 @@ export const SapHanaSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SapHanaSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -24812,9 +24927,9 @@ export const SapOpenHubSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SapOpenHubSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, excludeLastRequest: { @@ -24850,9 +24965,9 @@ export const SapOdpSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SapOdpSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, extractionMode: { @@ -24888,9 +25003,9 @@ export const SapTableSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SapTableSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, rowCount: { @@ -24957,9 +25072,9 @@ export const SqlSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SqlSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, sqlReaderQuery: { @@ -25011,9 +25126,9 @@ export const SqlServerSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SqlServerSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, sqlReaderQuery: { @@ -25065,9 +25180,9 @@ export const AmazonRdsForSqlServerSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "AmazonRdsForSqlServerSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, sqlReaderQuery: { @@ -25119,9 +25234,9 @@ export const AzureSqlSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "AzureSqlSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, sqlReaderQuery: { @@ -25173,9 +25288,9 @@ export const SqlMISource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SqlMISource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, sqlReaderQuery: { @@ -25227,9 +25342,9 @@ export const SqlDWSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SqlDWSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, sqlReaderQuery: { @@ -25272,9 +25387,9 @@ export const AzureMySqlSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "AzureMySqlSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25292,9 +25407,9 @@ export const TeradataSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "TeradataSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25325,9 +25440,9 @@ export const CassandraSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "CassandraSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25351,9 +25466,9 @@ export const AmazonMWSSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "AmazonMWSSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25371,9 +25486,9 @@ export const AzurePostgreSqlSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "AzurePostgreSqlSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25391,9 +25506,9 @@ export const ConcurSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "ConcurSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25411,9 +25526,9 @@ export const CouchbaseSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "CouchbaseSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25431,9 +25546,9 @@ export const DrillSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "DrillSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25451,9 +25566,9 @@ export const EloquaSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "EloquaSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25471,9 +25586,9 @@ export const GoogleBigQuerySource: coreClient.CompositeMapper = { type: { name: "Composite", className: "GoogleBigQuerySource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25491,9 +25606,9 @@ export const GreenplumSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "GreenplumSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25511,9 +25626,9 @@ export const HBaseSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "HBaseSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25531,9 +25646,9 @@ export const HiveSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "HiveSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25551,9 +25666,9 @@ export const HubspotSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "HubspotSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25571,9 +25686,9 @@ export const ImpalaSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "ImpalaSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25591,9 +25706,9 @@ export const JiraSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "JiraSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25611,9 +25726,9 @@ export const MagentoSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "MagentoSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25631,9 +25746,9 @@ export const MariaDBSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "MariaDBSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25651,9 +25766,9 @@ export const AzureMariaDBSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "AzureMariaDBSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25671,9 +25786,9 @@ export const MarketoSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "MarketoSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25691,9 +25806,9 @@ export const PaypalSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "PaypalSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25711,9 +25826,9 @@ export const PhoenixSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "PhoenixSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25731,9 +25846,9 @@ export const PrestoSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "PrestoSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25751,9 +25866,9 @@ export const QuickBooksSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "QuickBooksSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25771,9 +25886,9 @@ export const ServiceNowSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "ServiceNowSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25791,9 +25906,9 @@ export const ShopifySource: coreClient.CompositeMapper = { type: { name: "Composite", className: "ShopifySource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25811,9 +25926,9 @@ export const SparkSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SparkSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25831,9 +25946,9 @@ export const SquareSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SquareSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25851,9 +25966,9 @@ export const XeroSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "XeroSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25871,9 +25986,9 @@ export const ZohoSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "ZohoSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25891,9 +26006,9 @@ export const NetezzaSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "NetezzaSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25924,9 +26039,9 @@ export const VerticaSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "VerticaSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25944,9 +26059,9 @@ export const SalesforceMarketingCloudSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "SalesforceMarketingCloudSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25964,9 +26079,9 @@ export const ResponsysSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "ResponsysSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -25984,9 +26099,9 @@ export const DynamicsAXSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "DynamicsAXSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -26010,9 +26125,9 @@ export const OracleServiceCloudSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "OracleServiceCloudSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -26030,9 +26145,9 @@ export const GoogleAdWordsSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "GoogleAdWordsSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -26050,9 +26165,9 @@ export const AmazonRedshiftSource: coreClient.CompositeMapper = { type: { name: "Composite", className: "AmazonRedshiftSource", - uberParent: "CopySource", + uberParent: "TabularSource", additionalProperties: { type: { name: "Object" } }, - polymorphicDiscriminator: CopySource.type.polymorphicDiscriminator, + polymorphicDiscriminator: TabularSource.type.polymorphicDiscriminator, modelProperties: { ...TabularSource.type.modelProperties, query: { @@ -26077,8 +26192,9 @@ export const TumblingWindowTriggerDependencyReference: coreClient.CompositeMappe type: { name: "Composite", className: "TumblingWindowTriggerDependencyReference", - uberParent: "DependencyReference", - polymorphicDiscriminator: DependencyReference.type.polymorphicDiscriminator, + uberParent: "TriggerDependencyReference", + polymorphicDiscriminator: + TriggerDependencyReference.type.polymorphicDiscriminator, modelProperties: { ...TriggerDependencyReference.type.modelProperties, offset: { @@ -26612,6 +26728,7 @@ export let discriminators = { "LinkedService.Snowflake": SnowflakeLinkedService, "LinkedService.SharePointOnlineList": SharePointOnlineListLinkedService, "LinkedService.AzureSynapseArtifacts": AzureSynapseArtifactsLinkedService, + "LinkedService.PowerBIWorkspace": PowerBIWorkspaceLinkedService, "Activity.Container": ControlActivity, "Activity.Execution": ExecutionActivity, "Activity.SqlPoolStoredProcedure": SqlPoolStoredProcedureActivity, @@ -26750,106 +26867,106 @@ export let discriminators = { "DependencyReference.SelfDependencyTumblingWindowTriggerReference": SelfDependencyTumblingWindowTriggerReference, "LinkedIntegrationRuntimeType.Key": LinkedIntegrationRuntimeKeyAuthorization, "LinkedIntegrationRuntimeType.RBAC": LinkedIntegrationRuntimeRbacAuthorization, - "Activity.ExecutePipeline": ExecutePipelineActivity, - "Activity.IfCondition": IfConditionActivity, - "Activity.Switch": SwitchActivity, - "Activity.ForEach": ForEachActivity, - "Activity.Wait": WaitActivity, - "Activity.Fail": FailActivity, - "Activity.Until": UntilActivity, - "Activity.Validation": ValidationActivity, - "Activity.Filter": FilterActivity, - "Activity.SetVariable": SetVariableActivity, - "Activity.AppendVariable": AppendVariableActivity, - "Activity.WebHook": WebHookActivity, - "Activity.Copy": CopyActivity, - "Activity.HDInsightHive": HDInsightHiveActivity, - "Activity.HDInsightPig": HDInsightPigActivity, - "Activity.HDInsightMapReduce": HDInsightMapReduceActivity, - "Activity.HDInsightStreaming": HDInsightStreamingActivity, - "Activity.HDInsightSpark": HDInsightSparkActivity, - "Activity.ExecuteSSISPackage": ExecuteSsisPackageActivity, - "Activity.Custom": CustomActivity, - "Activity.SqlServerStoredProcedure": SqlServerStoredProcedureActivity, - "Activity.Delete": DeleteActivity, - "Activity.AzureDataExplorerCommand": AzureDataExplorerCommandActivity, - "Activity.Lookup": LookupActivity, - "Activity.WebActivity": WebActivity, - "Activity.GetMetadata": GetMetadataActivity, - "Activity.AzureMLBatchExecution": AzureMLBatchExecutionActivity, - "Activity.AzureMLUpdateResource": AzureMLUpdateResourceActivity, - "Activity.AzureMLExecutePipeline": AzureMLExecutePipelineActivity, - "Activity.DataLakeAnalyticsU-SQL": DataLakeAnalyticsUsqlActivity, - "Activity.DatabricksNotebook": DatabricksNotebookActivity, - "Activity.DatabricksSparkJar": DatabricksSparkJarActivity, - "Activity.DatabricksSparkPython": DatabricksSparkPythonActivity, - "Activity.AzureFunctionActivity": AzureFunctionActivity, - "Activity.ExecuteDataFlow": ExecuteDataFlowActivity, - "Activity.Script": ScriptActivity, - "Activity.SynapseNotebook": SynapseNotebookActivity, - "Activity.SparkJob": SynapseSparkJobDefinitionActivity, - "Trigger.ScheduleTrigger": ScheduleTrigger, - "Trigger.BlobTrigger": BlobTrigger, - "Trigger.BlobEventsTrigger": BlobEventsTrigger, - "Trigger.CustomEventsTrigger": CustomEventsTrigger, - "CopySource.AzureTableSource": AzureTableSource, - "CopySource.InformixSource": InformixSource, - "CopySource.Db2Source": Db2Source, - "CopySource.OdbcSource": OdbcSource, - "CopySource.MySqlSource": MySqlSource, - "CopySource.PostgreSqlSource": PostgreSqlSource, - "CopySource.SybaseSource": SybaseSource, - "CopySource.SapBwSource": SapBwSource, - "CopySource.SalesforceSource": SalesforceSource, - "CopySource.SapCloudForCustomerSource": SapCloudForCustomerSource, - "CopySource.SapEccSource": SapEccSource, - "CopySource.SapHanaSource": SapHanaSource, - "CopySource.SapOpenHubSource": SapOpenHubSource, - "CopySource.SapOdpSource": SapOdpSource, - "CopySource.SapTableSource": SapTableSource, - "CopySource.SqlSource": SqlSource, - "CopySource.SqlServerSource": SqlServerSource, - "CopySource.AmazonRdsForSqlServerSource": AmazonRdsForSqlServerSource, - "CopySource.AzureSqlSource": AzureSqlSource, - "CopySource.SqlMISource": SqlMISource, - "CopySource.SqlDWSource": SqlDWSource, - "CopySource.AzureMySqlSource": AzureMySqlSource, - "CopySource.TeradataSource": TeradataSource, - "CopySource.CassandraSource": CassandraSource, - "CopySource.AmazonMWSSource": AmazonMWSSource, - "CopySource.AzurePostgreSqlSource": AzurePostgreSqlSource, - "CopySource.ConcurSource": ConcurSource, - "CopySource.CouchbaseSource": CouchbaseSource, - "CopySource.DrillSource": DrillSource, - "CopySource.EloquaSource": EloquaSource, - "CopySource.GoogleBigQuerySource": GoogleBigQuerySource, - "CopySource.GreenplumSource": GreenplumSource, - "CopySource.HBaseSource": HBaseSource, - "CopySource.HiveSource": HiveSource, - "CopySource.HubspotSource": HubspotSource, - "CopySource.ImpalaSource": ImpalaSource, - "CopySource.JiraSource": JiraSource, - "CopySource.MagentoSource": MagentoSource, - "CopySource.MariaDBSource": MariaDBSource, - "CopySource.AzureMariaDBSource": AzureMariaDBSource, - "CopySource.MarketoSource": MarketoSource, - "CopySource.PaypalSource": PaypalSource, - "CopySource.PhoenixSource": PhoenixSource, - "CopySource.PrestoSource": PrestoSource, - "CopySource.QuickBooksSource": QuickBooksSource, - "CopySource.ServiceNowSource": ServiceNowSource, - "CopySource.ShopifySource": ShopifySource, - "CopySource.SparkSource": SparkSource, - "CopySource.SquareSource": SquareSource, - "CopySource.XeroSource": XeroSource, - "CopySource.ZohoSource": ZohoSource, - "CopySource.NetezzaSource": NetezzaSource, - "CopySource.VerticaSource": VerticaSource, - "CopySource.SalesforceMarketingCloudSource": SalesforceMarketingCloudSource, - "CopySource.ResponsysSource": ResponsysSource, - "CopySource.DynamicsAXSource": DynamicsAXSource, - "CopySource.OracleServiceCloudSource": OracleServiceCloudSource, - "CopySource.GoogleAdWordsSource": GoogleAdWordsSource, - "CopySource.AmazonRedshiftSource": AmazonRedshiftSource, - "DependencyReference.TumblingWindowTriggerDependencyReference": TumblingWindowTriggerDependencyReference + "ControlActivity.ExecutePipeline": ExecutePipelineActivity, + "ControlActivity.IfCondition": IfConditionActivity, + "ControlActivity.Switch": SwitchActivity, + "ControlActivity.ForEach": ForEachActivity, + "ControlActivity.Wait": WaitActivity, + "ControlActivity.Fail": FailActivity, + "ControlActivity.Until": UntilActivity, + "ControlActivity.Validation": ValidationActivity, + "ControlActivity.Filter": FilterActivity, + "ControlActivity.SetVariable": SetVariableActivity, + "ControlActivity.AppendVariable": AppendVariableActivity, + "ControlActivity.WebHook": WebHookActivity, + "ExecutionActivity.Copy": CopyActivity, + "ExecutionActivity.HDInsightHive": HDInsightHiveActivity, + "ExecutionActivity.HDInsightPig": HDInsightPigActivity, + "ExecutionActivity.HDInsightMapReduce": HDInsightMapReduceActivity, + "ExecutionActivity.HDInsightStreaming": HDInsightStreamingActivity, + "ExecutionActivity.HDInsightSpark": HDInsightSparkActivity, + "ExecutionActivity.ExecuteSSISPackage": ExecuteSsisPackageActivity, + "ExecutionActivity.Custom": CustomActivity, + "ExecutionActivity.SqlServerStoredProcedure": SqlServerStoredProcedureActivity, + "ExecutionActivity.Delete": DeleteActivity, + "ExecutionActivity.AzureDataExplorerCommand": AzureDataExplorerCommandActivity, + "ExecutionActivity.Lookup": LookupActivity, + "ExecutionActivity.WebActivity": WebActivity, + "ExecutionActivity.GetMetadata": GetMetadataActivity, + "ExecutionActivity.AzureMLBatchExecution": AzureMLBatchExecutionActivity, + "ExecutionActivity.AzureMLUpdateResource": AzureMLUpdateResourceActivity, + "ExecutionActivity.AzureMLExecutePipeline": AzureMLExecutePipelineActivity, + "ExecutionActivity.DataLakeAnalyticsU-SQL": DataLakeAnalyticsUsqlActivity, + "ExecutionActivity.DatabricksNotebook": DatabricksNotebookActivity, + "ExecutionActivity.DatabricksSparkJar": DatabricksSparkJarActivity, + "ExecutionActivity.DatabricksSparkPython": DatabricksSparkPythonActivity, + "ExecutionActivity.AzureFunctionActivity": AzureFunctionActivity, + "ExecutionActivity.ExecuteDataFlow": ExecuteDataFlowActivity, + "ExecutionActivity.Script": ScriptActivity, + "ExecutionActivity.SynapseNotebook": SynapseNotebookActivity, + "ExecutionActivity.SparkJob": SynapseSparkJobDefinitionActivity, + "MultiplePipelineTrigger.ScheduleTrigger": ScheduleTrigger, + "MultiplePipelineTrigger.BlobTrigger": BlobTrigger, + "MultiplePipelineTrigger.BlobEventsTrigger": BlobEventsTrigger, + "MultiplePipelineTrigger.CustomEventsTrigger": CustomEventsTrigger, + "TabularSource.AzureTableSource": AzureTableSource, + "TabularSource.InformixSource": InformixSource, + "TabularSource.Db2Source": Db2Source, + "TabularSource.OdbcSource": OdbcSource, + "TabularSource.MySqlSource": MySqlSource, + "TabularSource.PostgreSqlSource": PostgreSqlSource, + "TabularSource.SybaseSource": SybaseSource, + "TabularSource.SapBwSource": SapBwSource, + "TabularSource.SalesforceSource": SalesforceSource, + "TabularSource.SapCloudForCustomerSource": SapCloudForCustomerSource, + "TabularSource.SapEccSource": SapEccSource, + "TabularSource.SapHanaSource": SapHanaSource, + "TabularSource.SapOpenHubSource": SapOpenHubSource, + "TabularSource.SapOdpSource": SapOdpSource, + "TabularSource.SapTableSource": SapTableSource, + "TabularSource.SqlSource": SqlSource, + "TabularSource.SqlServerSource": SqlServerSource, + "TabularSource.AmazonRdsForSqlServerSource": AmazonRdsForSqlServerSource, + "TabularSource.AzureSqlSource": AzureSqlSource, + "TabularSource.SqlMISource": SqlMISource, + "TabularSource.SqlDWSource": SqlDWSource, + "TabularSource.AzureMySqlSource": AzureMySqlSource, + "TabularSource.TeradataSource": TeradataSource, + "TabularSource.CassandraSource": CassandraSource, + "TabularSource.AmazonMWSSource": AmazonMWSSource, + "TabularSource.AzurePostgreSqlSource": AzurePostgreSqlSource, + "TabularSource.ConcurSource": ConcurSource, + "TabularSource.CouchbaseSource": CouchbaseSource, + "TabularSource.DrillSource": DrillSource, + "TabularSource.EloquaSource": EloquaSource, + "TabularSource.GoogleBigQuerySource": GoogleBigQuerySource, + "TabularSource.GreenplumSource": GreenplumSource, + "TabularSource.HBaseSource": HBaseSource, + "TabularSource.HiveSource": HiveSource, + "TabularSource.HubspotSource": HubspotSource, + "TabularSource.ImpalaSource": ImpalaSource, + "TabularSource.JiraSource": JiraSource, + "TabularSource.MagentoSource": MagentoSource, + "TabularSource.MariaDBSource": MariaDBSource, + "TabularSource.AzureMariaDBSource": AzureMariaDBSource, + "TabularSource.MarketoSource": MarketoSource, + "TabularSource.PaypalSource": PaypalSource, + "TabularSource.PhoenixSource": PhoenixSource, + "TabularSource.PrestoSource": PrestoSource, + "TabularSource.QuickBooksSource": QuickBooksSource, + "TabularSource.ServiceNowSource": ServiceNowSource, + "TabularSource.ShopifySource": ShopifySource, + "TabularSource.SparkSource": SparkSource, + "TabularSource.SquareSource": SquareSource, + "TabularSource.XeroSource": XeroSource, + "TabularSource.ZohoSource": ZohoSource, + "TabularSource.NetezzaSource": NetezzaSource, + "TabularSource.VerticaSource": VerticaSource, + "TabularSource.SalesforceMarketingCloudSource": SalesforceMarketingCloudSource, + "TabularSource.ResponsysSource": ResponsysSource, + "TabularSource.DynamicsAXSource": DynamicsAXSource, + "TabularSource.OracleServiceCloudSource": OracleServiceCloudSource, + "TabularSource.GoogleAdWordsSource": GoogleAdWordsSource, + "TabularSource.AmazonRedshiftSource": AmazonRedshiftSource, + "TriggerDependencyReference.TumblingWindowTriggerDependencyReference": TumblingWindowTriggerDependencyReference }; diff --git a/sdk/synapse/synapse-artifacts/src/models/parameters.ts b/sdk/synapse/synapse-artifacts/src/models/parameters.ts index 70850a8d4491..d60f5f05173f 100644 --- a/sdk/synapse/synapse-artifacts/src/models/parameters.ts +++ b/sdk/synapse/synapse-artifacts/src/models/parameters.ts @@ -64,7 +64,7 @@ export const endpoint: OperationURLParameter = { export const apiVersion: OperationQueryParameter = { parameterPath: "apiVersion", mapper: { - defaultValue: "2022-08-01-preview", + defaultValue: "2022-12-01-preview", isConstant: true, serializedName: "api-version", type: { diff --git a/sdk/synapse/synapse-artifacts/src/operations/dataFlowDebugSession.ts b/sdk/synapse/synapse-artifacts/src/operations/dataFlowDebugSession.ts index 6b5e71c35d8c..6ad8676ec472 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/dataFlowDebugSession.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/dataFlowDebugSession.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { DataFlowDebugSession } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -19,10 +20,10 @@ import { DataFlowDebugSessionInfo, DataFlowDebugSessionQueryDataFlowDebugSessionsByWorkspaceNextOptionalParams, DataFlowDebugSessionQueryDataFlowDebugSessionsByWorkspaceOptionalParams, + DataFlowDebugSessionQueryDataFlowDebugSessionsByWorkspaceResponse, CreateDataFlowDebugSessionRequest, DataFlowDebugSessionCreateDataFlowDebugSessionOptionalParams, DataFlowDebugSessionCreateDataFlowDebugSessionResponse, - DataFlowDebugSessionQueryDataFlowDebugSessionsByWorkspaceResponse, DataFlowDebugPackage, DataFlowDebugSessionAddDataFlowOptionalParams, DataFlowDebugSessionAddDataFlowResponse, @@ -62,25 +63,40 @@ export class DataFlowDebugSessionImpl implements DataFlowDebugSession { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.queryDataFlowDebugSessionsByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.queryDataFlowDebugSessionsByWorkspacePagingPage( + options, + settings + ); } }; } private async *queryDataFlowDebugSessionsByWorkspacePagingPage( - options?: DataFlowDebugSessionQueryDataFlowDebugSessionsByWorkspaceOptionalParams + options?: DataFlowDebugSessionQueryDataFlowDebugSessionsByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._queryDataFlowDebugSessionsByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: DataFlowDebugSessionQueryDataFlowDebugSessionsByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._queryDataFlowDebugSessionsByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._queryDataFlowDebugSessionsByWorkspaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -479,7 +495,6 @@ const queryDataFlowDebugSessionsByWorkspaceNextOperationSpec: coreClient.Operati bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/dataFlowOperations.ts b/sdk/synapse/synapse-artifacts/src/operations/dataFlowOperations.ts index 4d3fb8fe7d64..e7810b110b85 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/dataFlowOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/dataFlowOperations.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { DataFlowOperations } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -19,6 +20,7 @@ import { DataFlowResource, DataFlowGetDataFlowsByWorkspaceNextOptionalParams, DataFlowGetDataFlowsByWorkspaceOptionalParams, + DataFlowGetDataFlowsByWorkspaceResponse, DataFlowCreateOrUpdateDataFlowOptionalParams, DataFlowCreateOrUpdateDataFlowResponse, DataFlowGetDataFlowOptionalParams, @@ -26,7 +28,6 @@ import { DataFlowDeleteDataFlowOptionalParams, ArtifactRenameRequest, DataFlowRenameDataFlowOptionalParams, - DataFlowGetDataFlowsByWorkspaceResponse, DataFlowGetDataFlowsByWorkspaceNextResponse } from "../models"; @@ -58,25 +59,37 @@ export class DataFlowOperationsImpl implements DataFlowOperations { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getDataFlowsByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getDataFlowsByWorkspacePagingPage(options, settings); } }; } private async *getDataFlowsByWorkspacePagingPage( - options?: DataFlowGetDataFlowsByWorkspaceOptionalParams + options?: DataFlowGetDataFlowsByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getDataFlowsByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: DataFlowGetDataFlowsByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getDataFlowsByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getDataFlowsByWorkspaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -526,7 +539,6 @@ const getDataFlowsByWorkspaceNextOperationSpec: coreClient.OperationSpec = { bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/datasetOperations.ts b/sdk/synapse/synapse-artifacts/src/operations/datasetOperations.ts index b0b60a239987..27d50114bd87 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/datasetOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/datasetOperations.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { DatasetOperations } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -58,25 +59,37 @@ export class DatasetOperationsImpl implements DatasetOperations { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getDatasetsByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getDatasetsByWorkspacePagingPage(options, settings); } }; } private async *getDatasetsByWorkspacePagingPage( - options?: DatasetGetDatasetsByWorkspaceOptionalParams + options?: DatasetGetDatasetsByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getDatasetsByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: DatasetGetDatasetsByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getDatasetsByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getDatasetsByWorkspaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -522,7 +535,6 @@ const getDatasetsByWorkspaceNextOperationSpec: coreClient.OperationSpec = { bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/kqlScripts.ts b/sdk/synapse/synapse-artifacts/src/operations/kqlScripts.ts index 4e1de728ccd0..d7d4207b03f9 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/kqlScripts.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/kqlScripts.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { KqlScripts } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -49,22 +50,34 @@ export class KqlScriptsImpl implements KqlScripts { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getAllPagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getAllPagingPage(options, settings); } }; } private async *getAllPagingPage( - options?: KqlScriptsGetAllOptionalParams + options?: KqlScriptsGetAllOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getAll(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: KqlScriptsGetAllResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getAll(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getAllNext(continuationToken, options); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -146,7 +159,6 @@ const getAllNextOperationSpec: coreClient.OperationSpec = { bodyMapper: Mappers.ErrorContract } }, - queryParameters: [Parameters.apiVersion1], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/library.ts b/sdk/synapse/synapse-artifacts/src/operations/library.ts index 3bf86d0e73db..3337734fd582 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/library.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/library.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { Library } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as coreRestPipeline from "@azure/core-rest-pipeline"; @@ -60,22 +61,34 @@ export class LibraryImpl implements Library { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.listPagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.listPagingPage(options, settings); } }; } private async *listPagingPage( - options?: LibraryListOptionalParams + options?: LibraryListOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._list(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: LibraryListOperationResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._list(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._listNext(continuationToken, options); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -578,7 +591,6 @@ const listNextOperationSpec: coreClient.OperationSpec = { bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/linkConnectionOperations.ts b/sdk/synapse/synapse-artifacts/src/operations/linkConnectionOperations.ts index 3dc087ed5216..f6541a1e3689 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/linkConnectionOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/linkConnectionOperations.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { LinkConnectionOperations } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -15,14 +16,14 @@ import * as Parameters from "../models/parameters"; import { ArtifactsClient } from "../artifactsClient"; import { LinkConnectionResource, - LinkConnectionListLinkConnectionsByWorkspaceNextOptionalParams, - LinkConnectionListLinkConnectionsByWorkspaceOptionalParams, - LinkConnectionListLinkConnectionsByWorkspaceResponse, - LinkConnectionCreateOrUpdateLinkConnectionOptionalParams, - LinkConnectionCreateOrUpdateLinkConnectionResponse, - LinkConnectionGetLinkConnectionOptionalParams, - LinkConnectionGetLinkConnectionResponse, - LinkConnectionDeleteLinkConnectionOptionalParams, + LinkConnectionListByWorkspaceNextOptionalParams, + LinkConnectionListByWorkspaceOptionalParams, + LinkConnectionListByWorkspaceResponse, + LinkConnectionCreateOrUpdateOptionalParams, + LinkConnectionCreateOrUpdateResponse, + LinkConnectionGetOptionalParams, + LinkConnectionGetResponse, + LinkConnectionDeleteOptionalParams, EditTablesRequest, LinkConnectionEditTablesOptionalParams, LinkConnectionStartOptionalParams, @@ -36,7 +37,9 @@ import { LinkConnectionQueryTableStatusResponse, UpdateLandingZoneCredential, LinkConnectionUpdateLandingZoneCredentialOptionalParams, - LinkConnectionListLinkConnectionsByWorkspaceNextResponse + LinkConnectionPauseOptionalParams, + LinkConnectionResumeOptionalParams, + LinkConnectionListByWorkspaceNextResponse } from "../models"; /// @@ -56,10 +59,10 @@ export class LinkConnectionOperationsImpl implements LinkConnectionOperations { * List link connections * @param options The options parameters. */ - public listLinkConnectionsByWorkspace( - options?: LinkConnectionListLinkConnectionsByWorkspaceOptionalParams + public listByWorkspace( + options?: LinkConnectionListByWorkspaceOptionalParams ): PagedAsyncIterableIterator { - const iter = this.listLinkConnectionsByWorkspacePagingAll(options); + const iter = this.listByWorkspacePagingAll(options); return { next() { return iter.next(); @@ -67,34 +70,41 @@ export class LinkConnectionOperationsImpl implements LinkConnectionOperations { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.listLinkConnectionsByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.listByWorkspacePagingPage(options, settings); } }; } - private async *listLinkConnectionsByWorkspacePagingPage( - options?: LinkConnectionListLinkConnectionsByWorkspaceOptionalParams + private async *listByWorkspacePagingPage( + options?: LinkConnectionListByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._listLinkConnectionsByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: LinkConnectionListByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._listByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { - result = await this._listLinkConnectionsByWorkspaceNext( - continuationToken, - options - ); + result = await this._listByWorkspaceNext(continuationToken, options); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } - private async *listLinkConnectionsByWorkspacePagingAll( - options?: LinkConnectionListLinkConnectionsByWorkspaceOptionalParams + private async *listByWorkspacePagingAll( + options?: LinkConnectionListByWorkspaceOptionalParams ): AsyncIterableIterator { - for await (const page of this.listLinkConnectionsByWorkspacePagingPage( - options - )) { + for await (const page of this.listByWorkspacePagingPage(options)) { yield* page; } } @@ -103,17 +113,17 @@ export class LinkConnectionOperationsImpl implements LinkConnectionOperations { * List link connections * @param options The options parameters. */ - private async _listLinkConnectionsByWorkspace( - options?: LinkConnectionListLinkConnectionsByWorkspaceOptionalParams - ): Promise { + private async _listByWorkspace( + options?: LinkConnectionListByWorkspaceOptionalParams + ): Promise { return tracingClient.withSpan( - "ArtifactsClient._listLinkConnectionsByWorkspace", + "ArtifactsClient._listByWorkspace", options ?? {}, async (options) => { return this.client.sendOperationRequest( { options }, - listLinkConnectionsByWorkspaceOperationSpec - ) as Promise; + listByWorkspaceOperationSpec + ) as Promise; } ); } @@ -124,19 +134,19 @@ export class LinkConnectionOperationsImpl implements LinkConnectionOperations { * @param linkConnection Link connection resource definition * @param options The options parameters. */ - async createOrUpdateLinkConnection( + async createOrUpdate( linkConnectionName: string, linkConnection: LinkConnectionResource, - options?: LinkConnectionCreateOrUpdateLinkConnectionOptionalParams - ): Promise { + options?: LinkConnectionCreateOrUpdateOptionalParams + ): Promise { return tracingClient.withSpan( - "ArtifactsClient.createOrUpdateLinkConnection", + "ArtifactsClient.createOrUpdate", options ?? {}, async (options) => { return this.client.sendOperationRequest( { linkConnectionName, linkConnection, options }, - createOrUpdateLinkConnectionOperationSpec - ) as Promise; + createOrUpdateOperationSpec + ) as Promise; } ); } @@ -146,18 +156,18 @@ export class LinkConnectionOperationsImpl implements LinkConnectionOperations { * @param linkConnectionName The link connection name * @param options The options parameters. */ - async getLinkConnection( + async get( linkConnectionName: string, - options?: LinkConnectionGetLinkConnectionOptionalParams - ): Promise { + options?: LinkConnectionGetOptionalParams + ): Promise { return tracingClient.withSpan( - "ArtifactsClient.getLinkConnection", + "ArtifactsClient.get", options ?? {}, async (options) => { return this.client.sendOperationRequest( { linkConnectionName, options }, - getLinkConnectionOperationSpec - ) as Promise; + getOperationSpec + ) as Promise; } ); } @@ -167,17 +177,17 @@ export class LinkConnectionOperationsImpl implements LinkConnectionOperations { * @param linkConnectionName The link connection name * @param options The options parameters. */ - async deleteLinkConnection( + async delete( linkConnectionName: string, - options?: LinkConnectionDeleteLinkConnectionOptionalParams + options?: LinkConnectionDeleteOptionalParams ): Promise { return tracingClient.withSpan( - "ArtifactsClient.deleteLinkConnection", + "ArtifactsClient.delete", options ?? {}, async (options) => { return this.client.sendOperationRequest( { linkConnectionName, options }, - deleteLinkConnectionOperationSpec + deleteOperationSpec ) as Promise; } ); @@ -207,7 +217,8 @@ export class LinkConnectionOperationsImpl implements LinkConnectionOperations { } /** - * Start a link connection + * Start a link connection. It may take a few minutes from Starting to Running, monitor the status with + * LinkConnection_GetDetailedStatus. * @param linkConnectionName The link connection name * @param options The options parameters. */ @@ -228,7 +239,8 @@ export class LinkConnectionOperationsImpl implements LinkConnectionOperations { } /** - * Stop a link connection + * Stop a link connection. It may take a few minutes from Stopping to stopped, monitor the status with + * LinkConnection_GetDetailedStatus. * @param linkConnectionName The link connection name * @param options The options parameters. */ @@ -337,23 +349,66 @@ export class LinkConnectionOperationsImpl implements LinkConnectionOperations { } /** - * ListLinkConnectionsByWorkspaceNext - * @param nextLink The nextLink from the previous successful call to the ListLinkConnectionsByWorkspace - * method. + * Pause a link connection. It may take a few minutes from Pausing to Paused, monitor the status with + * LinkConnection_GetDetailedStatus. + * @param linkConnectionName The link connection name + * @param options The options parameters. + */ + async pause( + linkConnectionName: string, + options?: LinkConnectionPauseOptionalParams + ): Promise { + return tracingClient.withSpan( + "ArtifactsClient.pause", + options ?? {}, + async (options) => { + return this.client.sendOperationRequest( + { linkConnectionName, options }, + pauseOperationSpec + ) as Promise; + } + ); + } + + /** + * Resume a link connection. It may take a few minutes from Resuming to Running, monitor the status + * with LinkConnection_GetDetailedStatus. + * @param linkConnectionName The link connection name * @param options The options parameters. */ - private async _listLinkConnectionsByWorkspaceNext( + async resume( + linkConnectionName: string, + options?: LinkConnectionResumeOptionalParams + ): Promise { + return tracingClient.withSpan( + "ArtifactsClient.resume", + options ?? {}, + async (options) => { + return this.client.sendOperationRequest( + { linkConnectionName, options }, + resumeOperationSpec + ) as Promise; + } + ); + } + + /** + * ListByWorkspaceNext + * @param nextLink The nextLink from the previous successful call to the ListByWorkspace method. + * @param options The options parameters. + */ + private async _listByWorkspaceNext( nextLink: string, - options?: LinkConnectionListLinkConnectionsByWorkspaceNextOptionalParams - ): Promise { + options?: LinkConnectionListByWorkspaceNextOptionalParams + ): Promise { return tracingClient.withSpan( - "ArtifactsClient._listLinkConnectionsByWorkspaceNext", + "ArtifactsClient._listByWorkspaceNext", options ?? {}, async (options) => { return this.client.sendOperationRequest( { nextLink, options }, - listLinkConnectionsByWorkspaceNextOperationSpec - ) as Promise; + listByWorkspaceNextOperationSpec + ) as Promise; } ); } @@ -361,7 +416,7 @@ export class LinkConnectionOperationsImpl implements LinkConnectionOperations { // Operation Specifications const serializer = coreClient.createSerializer(Mappers, /* isXml */ false); -const listLinkConnectionsByWorkspaceOperationSpec: coreClient.OperationSpec = { +const listByWorkspaceOperationSpec: coreClient.OperationSpec = { path: "/linkconnections", httpMethod: "GET", responses: { @@ -377,7 +432,7 @@ const listLinkConnectionsByWorkspaceOperationSpec: coreClient.OperationSpec = { headerParameters: [Parameters.accept], serializer }; -const createOrUpdateLinkConnectionOperationSpec: coreClient.OperationSpec = { +const createOrUpdateOperationSpec: coreClient.OperationSpec = { path: "/linkconnections/{linkConnectionName}", httpMethod: "PUT", responses: { @@ -395,7 +450,7 @@ const createOrUpdateLinkConnectionOperationSpec: coreClient.OperationSpec = { mediaType: "json", serializer }; -const getLinkConnectionOperationSpec: coreClient.OperationSpec = { +const getOperationSpec: coreClient.OperationSpec = { path: "/linkconnections/{linkConnectionName}", httpMethod: "GET", responses: { @@ -411,7 +466,7 @@ const getLinkConnectionOperationSpec: coreClient.OperationSpec = { headerParameters: [Parameters.accept], serializer }; -const deleteLinkConnectionOperationSpec: coreClient.OperationSpec = { +const deleteOperationSpec: coreClient.OperationSpec = { path: "/linkconnections/{linkConnectionName}", httpMethod: "DELETE", responses: { @@ -536,7 +591,35 @@ const updateLandingZoneCredentialOperationSpec: coreClient.OperationSpec = { mediaType: "json", serializer }; -const listLinkConnectionsByWorkspaceNextOperationSpec: coreClient.OperationSpec = { +const pauseOperationSpec: coreClient.OperationSpec = { + path: "/linkconnections/{linkConnectionName}/pause", + httpMethod: "POST", + responses: { + 200: {}, + default: { + bodyMapper: Mappers.CloudError + } + }, + queryParameters: [Parameters.apiVersion], + urlParameters: [Parameters.endpoint, Parameters.linkConnectionName], + headerParameters: [Parameters.accept], + serializer +}; +const resumeOperationSpec: coreClient.OperationSpec = { + path: "/linkconnections/{linkConnectionName}/resume", + httpMethod: "POST", + responses: { + 200: {}, + default: { + bodyMapper: Mappers.CloudError + } + }, + queryParameters: [Parameters.apiVersion], + urlParameters: [Parameters.endpoint, Parameters.linkConnectionName], + headerParameters: [Parameters.accept], + serializer +}; +const listByWorkspaceNextOperationSpec: coreClient.OperationSpec = { path: "{nextLink}", httpMethod: "GET", responses: { @@ -547,7 +630,6 @@ const listLinkConnectionsByWorkspaceNextOperationSpec: coreClient.OperationSpec bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/linkedServiceOperations.ts b/sdk/synapse/synapse-artifacts/src/operations/linkedServiceOperations.ts index a0accb6b9066..13b737d32e90 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/linkedServiceOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/linkedServiceOperations.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { LinkedServiceOperations } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -58,25 +59,37 @@ export class LinkedServiceOperationsImpl implements LinkedServiceOperations { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getLinkedServicesByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getLinkedServicesByWorkspacePagingPage(options, settings); } }; } private async *getLinkedServicesByWorkspacePagingPage( - options?: LinkedServiceGetLinkedServicesByWorkspaceOptionalParams + options?: LinkedServiceGetLinkedServicesByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getLinkedServicesByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: LinkedServiceGetLinkedServicesByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getLinkedServicesByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getLinkedServicesByWorkspaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -532,7 +545,6 @@ const getLinkedServicesByWorkspaceNextOperationSpec: coreClient.OperationSpec = bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/notebookOperations.ts b/sdk/synapse/synapse-artifacts/src/operations/notebookOperations.ts index c80f845a0dc6..a1a2804276be 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/notebookOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/notebookOperations.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { NotebookOperations } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -19,9 +20,9 @@ import { NotebookResource, NotebookGetNotebooksByWorkspaceNextOptionalParams, NotebookGetNotebooksByWorkspaceOptionalParams, + NotebookGetNotebooksByWorkspaceResponse, NotebookGetNotebookSummaryByWorkSpaceNextOptionalParams, NotebookGetNotebookSummaryByWorkSpaceOptionalParams, - NotebookGetNotebooksByWorkspaceResponse, NotebookGetNotebookSummaryByWorkSpaceResponse, NotebookCreateOrUpdateNotebookOptionalParams, NotebookCreateOrUpdateNotebookResponse, @@ -62,25 +63,37 @@ export class NotebookOperationsImpl implements NotebookOperations { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getNotebooksByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getNotebooksByWorkspacePagingPage(options, settings); } }; } private async *getNotebooksByWorkspacePagingPage( - options?: NotebookGetNotebooksByWorkspaceOptionalParams + options?: NotebookGetNotebooksByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getNotebooksByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: NotebookGetNotebooksByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getNotebooksByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getNotebooksByWorkspaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -107,25 +120,37 @@ export class NotebookOperationsImpl implements NotebookOperations { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getNotebookSummaryByWorkSpacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getNotebookSummaryByWorkSpacePagingPage(options, settings); } }; } private async *getNotebookSummaryByWorkSpacePagingPage( - options?: NotebookGetNotebookSummaryByWorkSpaceOptionalParams + options?: NotebookGetNotebookSummaryByWorkSpaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getNotebookSummaryByWorkSpace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: NotebookGetNotebookSummaryByWorkSpaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getNotebookSummaryByWorkSpace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getNotebookSummaryByWorkSpaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -635,7 +660,6 @@ const getNotebooksByWorkspaceNextOperationSpec: coreClient.OperationSpec = { bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer @@ -651,7 +675,6 @@ const getNotebookSummaryByWorkSpaceNextOperationSpec: coreClient.OperationSpec = bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/pipelineOperations.ts b/sdk/synapse/synapse-artifacts/src/operations/pipelineOperations.ts index 1da95ca9f468..36424f0d2ccb 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/pipelineOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/pipelineOperations.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { PipelineOperations } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -60,25 +61,37 @@ export class PipelineOperationsImpl implements PipelineOperations { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getPipelinesByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getPipelinesByWorkspacePagingPage(options, settings); } }; } private async *getPipelinesByWorkspacePagingPage( - options?: PipelineGetPipelinesByWorkspaceOptionalParams + options?: PipelineGetPipelinesByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getPipelinesByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: PipelineGetPipelinesByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getPipelinesByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getPipelinesByWorkspaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -573,7 +586,6 @@ const getPipelinesByWorkspaceNextOperationSpec: coreClient.OperationSpec = { bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/sparkConfigurationOperations.ts b/sdk/synapse/synapse-artifacts/src/operations/sparkConfigurationOperations.ts index dd95661a33ff..10dff93851de 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/sparkConfigurationOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/sparkConfigurationOperations.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { SparkConfigurationOperations } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -59,25 +60,40 @@ export class SparkConfigurationOperationsImpl [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getSparkConfigurationsByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getSparkConfigurationsByWorkspacePagingPage( + options, + settings + ); } }; } private async *getSparkConfigurationsByWorkspacePagingPage( - options?: SparkConfigurationGetSparkConfigurationsByWorkspaceOptionalParams + options?: SparkConfigurationGetSparkConfigurationsByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getSparkConfigurationsByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: SparkConfigurationGetSparkConfigurationsByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getSparkConfigurationsByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getSparkConfigurationsByWorkspaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -539,7 +555,6 @@ const getSparkConfigurationsByWorkspaceNextOperationSpec: coreClient.OperationSp bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion3], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/sparkJobDefinitionOperations.ts b/sdk/synapse/synapse-artifacts/src/operations/sparkJobDefinitionOperations.ts index 8e1b91c16181..1072e2ce65d7 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/sparkJobDefinitionOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/sparkJobDefinitionOperations.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { SparkJobDefinitionOperations } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -63,25 +64,40 @@ export class SparkJobDefinitionOperationsImpl [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getSparkJobDefinitionsByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getSparkJobDefinitionsByWorkspacePagingPage( + options, + settings + ); } }; } private async *getSparkJobDefinitionsByWorkspacePagingPage( - options?: SparkJobDefinitionGetSparkJobDefinitionsByWorkspaceOptionalParams + options?: SparkJobDefinitionGetSparkJobDefinitionsByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getSparkJobDefinitionsByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: SparkJobDefinitionGetSparkJobDefinitionsByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getSparkJobDefinitionsByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getSparkJobDefinitionsByWorkspaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -777,7 +793,6 @@ const getSparkJobDefinitionsByWorkspaceNextOperationSpec: coreClient.OperationSp bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/sqlScriptOperations.ts b/sdk/synapse/synapse-artifacts/src/operations/sqlScriptOperations.ts index 7314a3d9581d..31f791464e5a 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/sqlScriptOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/sqlScriptOperations.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { SqlScriptOperations } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -58,25 +59,37 @@ export class SqlScriptOperationsImpl implements SqlScriptOperations { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getSqlScriptsByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getSqlScriptsByWorkspacePagingPage(options, settings); } }; } private async *getSqlScriptsByWorkspacePagingPage( - options?: SqlScriptGetSqlScriptsByWorkspaceOptionalParams + options?: SqlScriptGetSqlScriptsByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getSqlScriptsByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: SqlScriptGetSqlScriptsByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getSqlScriptsByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getSqlScriptsByWorkspaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -527,7 +540,6 @@ const getSqlScriptsByWorkspaceNextOperationSpec: coreClient.OperationSpec = { bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operations/triggerOperations.ts b/sdk/synapse/synapse-artifacts/src/operations/triggerOperations.ts index 669fba1a48f5..6f14ad355e4e 100644 --- a/sdk/synapse/synapse-artifacts/src/operations/triggerOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operations/triggerOperations.ts @@ -7,7 +7,8 @@ */ import { tracingClient } from "../tracing"; -import { PagedAsyncIterableIterator } from "@azure/core-paging"; +import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging"; +import { setContinuationToken } from "../pagingHelper"; import { TriggerOperations } from "../operationsInterfaces"; import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; @@ -64,25 +65,37 @@ export class TriggerOperationsImpl implements TriggerOperations { [Symbol.asyncIterator]() { return this; }, - byPage: () => { - return this.getTriggersByWorkspacePagingPage(options); + byPage: (settings?: PageSettings) => { + if (settings?.maxPageSize) { + throw new Error("maxPageSize is not supported by this operation."); + } + return this.getTriggersByWorkspacePagingPage(options, settings); } }; } private async *getTriggersByWorkspacePagingPage( - options?: TriggerGetTriggersByWorkspaceOptionalParams + options?: TriggerGetTriggersByWorkspaceOptionalParams, + settings?: PageSettings ): AsyncIterableIterator { - let result = await this._getTriggersByWorkspace(options); - yield result.value || []; - let continuationToken = result.nextLink; + let result: TriggerGetTriggersByWorkspaceResponse; + let continuationToken = settings?.continuationToken; + if (!continuationToken) { + result = await this._getTriggersByWorkspace(options); + let page = result.value || []; + continuationToken = result.nextLink; + setContinuationToken(page, continuationToken); + yield page; + } while (continuationToken) { result = await this._getTriggersByWorkspaceNext( continuationToken, options ); continuationToken = result.nextLink; - yield result.value || []; + let page = result.value || []; + setContinuationToken(page, continuationToken); + yield page; } } @@ -886,7 +899,6 @@ const getTriggersByWorkspaceNextOperationSpec: coreClient.OperationSpec = { bodyMapper: Mappers.CloudError } }, - queryParameters: [Parameters.apiVersion4], urlParameters: [Parameters.endpoint, Parameters.nextLink], headerParameters: [Parameters.accept], serializer diff --git a/sdk/synapse/synapse-artifacts/src/operationsInterfaces/linkConnectionOperations.ts b/sdk/synapse/synapse-artifacts/src/operationsInterfaces/linkConnectionOperations.ts index c8e4a2412015..a2b3205a2ece 100644 --- a/sdk/synapse/synapse-artifacts/src/operationsInterfaces/linkConnectionOperations.ts +++ b/sdk/synapse/synapse-artifacts/src/operationsInterfaces/linkConnectionOperations.ts @@ -9,12 +9,12 @@ import { PagedAsyncIterableIterator } from "@azure/core-paging"; import { LinkConnectionResource, - LinkConnectionListLinkConnectionsByWorkspaceOptionalParams, - LinkConnectionCreateOrUpdateLinkConnectionOptionalParams, - LinkConnectionCreateOrUpdateLinkConnectionResponse, - LinkConnectionGetLinkConnectionOptionalParams, - LinkConnectionGetLinkConnectionResponse, - LinkConnectionDeleteLinkConnectionOptionalParams, + LinkConnectionListByWorkspaceOptionalParams, + LinkConnectionCreateOrUpdateOptionalParams, + LinkConnectionCreateOrUpdateResponse, + LinkConnectionGetOptionalParams, + LinkConnectionGetResponse, + LinkConnectionDeleteOptionalParams, EditTablesRequest, LinkConnectionEditTablesOptionalParams, LinkConnectionStartOptionalParams, @@ -27,7 +27,9 @@ import { LinkConnectionQueryTableStatusOptionalParams, LinkConnectionQueryTableStatusResponse, UpdateLandingZoneCredential, - LinkConnectionUpdateLandingZoneCredentialOptionalParams + LinkConnectionUpdateLandingZoneCredentialOptionalParams, + LinkConnectionPauseOptionalParams, + LinkConnectionResumeOptionalParams } from "../models"; /// @@ -37,8 +39,8 @@ export interface LinkConnectionOperations { * List link connections * @param options The options parameters. */ - listLinkConnectionsByWorkspace( - options?: LinkConnectionListLinkConnectionsByWorkspaceOptionalParams + listByWorkspace( + options?: LinkConnectionListByWorkspaceOptionalParams ): PagedAsyncIterableIterator; /** * Creates or updates a link connection @@ -46,28 +48,28 @@ export interface LinkConnectionOperations { * @param linkConnection Link connection resource definition * @param options The options parameters. */ - createOrUpdateLinkConnection( + createOrUpdate( linkConnectionName: string, linkConnection: LinkConnectionResource, - options?: LinkConnectionCreateOrUpdateLinkConnectionOptionalParams - ): Promise; + options?: LinkConnectionCreateOrUpdateOptionalParams + ): Promise; /** * Get a link connection * @param linkConnectionName The link connection name * @param options The options parameters. */ - getLinkConnection( + get( linkConnectionName: string, - options?: LinkConnectionGetLinkConnectionOptionalParams - ): Promise; + options?: LinkConnectionGetOptionalParams + ): Promise; /** * Delete a link connection * @param linkConnectionName The link connection name * @param options The options parameters. */ - deleteLinkConnection( + delete( linkConnectionName: string, - options?: LinkConnectionDeleteLinkConnectionOptionalParams + options?: LinkConnectionDeleteOptionalParams ): Promise; /** * Edit tables for a link connection @@ -81,7 +83,8 @@ export interface LinkConnectionOperations { options?: LinkConnectionEditTablesOptionalParams ): Promise; /** - * Start a link connection + * Start a link connection. It may take a few minutes from Starting to Running, monitor the status with + * LinkConnection_GetDetailedStatus. * @param linkConnectionName The link connection name * @param options The options parameters. */ @@ -90,7 +93,8 @@ export interface LinkConnectionOperations { options?: LinkConnectionStartOptionalParams ): Promise; /** - * Stop a link connection + * Stop a link connection. It may take a few minutes from Stopping to stopped, monitor the status with + * LinkConnection_GetDetailedStatus. * @param linkConnectionName The link connection name * @param options The options parameters. */ @@ -138,4 +142,24 @@ export interface LinkConnectionOperations { updateLandingZoneCredentialRequest: UpdateLandingZoneCredential, options?: LinkConnectionUpdateLandingZoneCredentialOptionalParams ): Promise; + /** + * Pause a link connection. It may take a few minutes from Pausing to Paused, monitor the status with + * LinkConnection_GetDetailedStatus. + * @param linkConnectionName The link connection name + * @param options The options parameters. + */ + pause( + linkConnectionName: string, + options?: LinkConnectionPauseOptionalParams + ): Promise; + /** + * Resume a link connection. It may take a few minutes from Resuming to Running, monitor the status + * with LinkConnection_GetDetailedStatus. + * @param linkConnectionName The link connection name + * @param options The options parameters. + */ + resume( + linkConnectionName: string, + options?: LinkConnectionResumeOptionalParams + ): Promise; } diff --git a/sdk/synapse/synapse-artifacts/src/pagingHelper.ts b/sdk/synapse/synapse-artifacts/src/pagingHelper.ts new file mode 100644 index 000000000000..269a2b9814b5 --- /dev/null +++ b/sdk/synapse/synapse-artifacts/src/pagingHelper.ts @@ -0,0 +1,39 @@ +/* + * Copyright (c) Microsoft Corporation. + * Licensed under the MIT License. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + * Changes may cause incorrect behavior and will be lost if the code is regenerated. + */ + +export interface PageInfo { + continuationToken?: string; +} + +const pageMap = new WeakMap(); + +/** + * Given the last `.value` produced by the `byPage` iterator, + * returns a continuation token that can be used to begin paging from + * that point later. + * @param page An object from accessing `value` on the IteratorResult from a `byPage` iterator. + * @returns The continuation token that can be passed into byPage() during future calls. + */ +export function getContinuationToken(page: unknown): string | undefined { + if (typeof page !== "object" || page === null) { + return undefined; + } + return pageMap.get(page)?.continuationToken; +} + +export function setContinuationToken( + page: unknown, + continuationToken: string | undefined +): void { + if (typeof page !== "object" || page === null || !continuationToken) { + return; + } + const pageInfo = pageMap.get(page) ?? {}; + pageInfo.continuationToken = continuationToken; + pageMap.set(page, pageInfo); +} diff --git a/sdk/synapse/synapse-artifacts/src/tracing.ts b/sdk/synapse/synapse-artifacts/src/tracing.ts index 4836b73cbacd..39872dd38b65 100644 --- a/sdk/synapse/synapse-artifacts/src/tracing.ts +++ b/sdk/synapse/synapse-artifacts/src/tracing.ts @@ -11,5 +11,5 @@ import { createTracingClient } from "@azure/core-tracing"; export const tracingClient = createTracingClient({ namespace: "Azure.Synapse.Artifacts", packageName: "@azure/synapse-artifacts", - packageVersion: "1.0.0-beta.13" + packageVersion: "1.0.0-beta.12" }); diff --git a/sdk/synapse/synapse-artifacts/swagger/README.md b/sdk/synapse/synapse-artifacts/swagger/README.md index 650318517780..0494c49a1117 100644 --- a/sdk/synapse/synapse-artifacts/swagger/README.md +++ b/sdk/synapse/synapse-artifacts/swagger/README.md @@ -18,10 +18,10 @@ clear-output-folder: false tracing-info: namespace: "Azure.Synapse.Artifacts" packagePrefix: "Microsoft.Synapse" -require: https://raw.githubusercontent.com/Azure/azure-rest-api-specs/e24bbf6a66cb0a19c072c6f15cee163acbd7acf7/specification/synapse/data-plane/readme.md +require: https://raw.githubusercontent.com/Azure/azure-rest-api-specs/61a8b1a62420c393fe5276c47373ea8dce74a985/specification/synapse/data-plane/readme.md use-extension: "@autorest/typescript": "latest" -tag: package-artifacts-composite-v5 +tag: package-artifacts-composite-v6 typescript: generate-metadata: false