diff --git a/profiles/preview/datafactory/mgmt/datafactory/models.go b/profiles/preview/datafactory/mgmt/datafactory/models.go index 089940190ab8..2c518b420928 100644 --- a/profiles/preview/datafactory/mgmt/datafactory/models.go +++ b/profiles/preview/datafactory/mgmt/datafactory/models.go @@ -547,6 +547,7 @@ type TypeBasicActivity = original.TypeBasicActivity const ( TypeActivity TypeBasicActivity = original.TypeActivity + TypeAppendVariable TypeBasicActivity = original.TypeAppendVariable TypeAzureMLBatchExecution TypeBasicActivity = original.TypeAzureMLBatchExecution TypeAzureMLUpdateResource TypeBasicActivity = original.TypeAzureMLUpdateResource TypeContainer TypeBasicActivity = original.TypeContainer @@ -569,6 +570,7 @@ const ( TypeHDInsightStreaming TypeBasicActivity = original.TypeHDInsightStreaming TypeIfCondition TypeBasicActivity = original.TypeIfCondition TypeLookup TypeBasicActivity = original.TypeLookup + TypeSetVariable TypeBasicActivity = original.TypeSetVariable TypeSQLServerStoredProcedure TypeBasicActivity = original.TypeSQLServerStoredProcedure TypeUntil TypeBasicActivity = original.TypeUntil TypeWait TypeBasicActivity = original.TypeWait @@ -860,6 +862,14 @@ const ( TypeTumblingWindowTrigger TypeBasicTrigger = original.TypeTumblingWindowTrigger ) +type VariableType = original.VariableType + +const ( + VariableTypeArray VariableType = original.VariableTypeArray + VariableTypeBool VariableType = original.VariableTypeBool + VariableTypeString VariableType = original.VariableTypeString +) + type WebActivityMethod = original.WebActivityMethod const ( @@ -886,6 +896,8 @@ type AmazonS3Dataset = original.AmazonS3Dataset type AmazonS3DatasetTypeProperties = original.AmazonS3DatasetTypeProperties type AmazonS3LinkedService = original.AmazonS3LinkedService type AmazonS3LinkedServiceTypeProperties = original.AmazonS3LinkedServiceTypeProperties +type AppendVariableActivity = original.AppendVariableActivity +type AppendVariableActivityTypeProperties = original.AppendVariableActivityTypeProperties type AvroFormat = original.AvroFormat type AzureBatchLinkedService = original.AzureBatchLinkedService type AzureBatchLinkedServiceTypeProperties = original.AzureBatchLinkedServiceTypeProperties @@ -1063,6 +1075,8 @@ type FtpServerLinkedService = original.FtpServerLinkedService type FtpServerLinkedServiceTypeProperties = original.FtpServerLinkedServiceTypeProperties type GetMetadataActivity = original.GetMetadataActivity type GetMetadataActivityTypeProperties = original.GetMetadataActivityTypeProperties +type GitHubAccessTokenRequest = original.GitHubAccessTokenRequest +type GitHubAccessTokenResponse = original.GitHubAccessTokenResponse type GoogleBigQueryLinkedService = original.GoogleBigQueryLinkedService type GoogleBigQueryLinkedServiceTypeProperties = original.GoogleBigQueryLinkedServiceTypeProperties type GoogleBigQueryObjectDataset = original.GoogleBigQueryObjectDataset @@ -1300,6 +1314,8 @@ type ServiceNowLinkedService = original.ServiceNowLinkedService type ServiceNowLinkedServiceTypeProperties = original.ServiceNowLinkedServiceTypeProperties type ServiceNowObjectDataset = original.ServiceNowObjectDataset type ServiceNowSource = original.ServiceNowSource +type SetVariableActivity = original.SetVariableActivity +type SetVariableActivityTypeProperties = original.SetVariableActivityTypeProperties type SftpServerLinkedService = original.SftpServerLinkedService type SftpServerLinkedServiceTypeProperties = original.SftpServerLinkedServiceTypeProperties type ShopifyLinkedService = original.ShopifyLinkedService @@ -1358,6 +1374,7 @@ type UntilActivityTypeProperties = original.UntilActivityTypeProperties type UpdateIntegrationRuntimeNodeRequest = original.UpdateIntegrationRuntimeNodeRequest type UpdateIntegrationRuntimeRequest = original.UpdateIntegrationRuntimeRequest type UserProperty = original.UserProperty +type VariableSpecification = original.VariableSpecification type VerticaLinkedService = original.VerticaLinkedService type VerticaLinkedServiceTypeProperties = original.VerticaLinkedServiceTypeProperties type VerticaSource = original.VerticaSource @@ -1651,6 +1668,9 @@ func PossibleTypeBasicLinkedServiceValues() []TypeBasicLinkedService { func PossibleTypeBasicTriggerValues() []TypeBasicTrigger { return original.PossibleTypeBasicTriggerValues() } +func PossibleVariableTypeValues() []VariableType { + return original.PossibleVariableTypeValues() +} func PossibleWebActivityMethodValues() []WebActivityMethod { return original.PossibleWebActivityMethodValues() } diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/factories.go b/services/datafactory/mgmt/2018-06-01/datafactory/factories.go index a2ab5e18a464..0dc011eef5b4 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/factories.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/factories.go @@ -382,6 +382,91 @@ func (client FactoriesClient) GetResponder(resp *http.Response) (result Factory, return } +// GetGitHubAccessToken get GitHub Access Token. +// Parameters: +// resourceGroupName - the resource group name. +// factoryName - the factory name. +// gitHubAccessTokenRequest - get GitHub access token request definition. +func (client FactoriesClient) GetGitHubAccessToken(ctx context.Context, resourceGroupName string, factoryName string, gitHubAccessTokenRequest GitHubAccessTokenRequest) (result GitHubAccessTokenResponse, err error) { + if err := validation.Validate([]validation.Validation{ + {TargetValue: resourceGroupName, + Constraints: []validation.Constraint{{Target: "resourceGroupName", Name: validation.MaxLength, Rule: 90, Chain: nil}, + {Target: "resourceGroupName", Name: validation.MinLength, Rule: 1, Chain: nil}, + {Target: "resourceGroupName", Name: validation.Pattern, Rule: `^[-\w\._\(\)]+$`, Chain: nil}}}, + {TargetValue: factoryName, + Constraints: []validation.Constraint{{Target: "factoryName", Name: validation.MaxLength, Rule: 63, Chain: nil}, + {Target: "factoryName", Name: validation.MinLength, Rule: 3, Chain: nil}, + {Target: "factoryName", Name: validation.Pattern, Rule: `^[A-Za-z0-9]+(?:-[A-Za-z0-9]+)*$`, Chain: nil}}}, + {TargetValue: gitHubAccessTokenRequest, + Constraints: []validation.Constraint{{Target: "gitHubAccessTokenRequest.GitHubAccessCode", Name: validation.Null, Rule: true, Chain: nil}, + {Target: "gitHubAccessTokenRequest.GitHubAccessTokenBaseURL", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { + return result, validation.NewError("datafactory.FactoriesClient", "GetGitHubAccessToken", err.Error()) + } + + req, err := client.GetGitHubAccessTokenPreparer(ctx, resourceGroupName, factoryName, gitHubAccessTokenRequest) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.FactoriesClient", "GetGitHubAccessToken", nil, "Failure preparing request") + return + } + + resp, err := client.GetGitHubAccessTokenSender(req) + if err != nil { + result.Response = autorest.Response{Response: resp} + err = autorest.NewErrorWithError(err, "datafactory.FactoriesClient", "GetGitHubAccessToken", resp, "Failure sending request") + return + } + + result, err = client.GetGitHubAccessTokenResponder(resp) + if err != nil { + err = autorest.NewErrorWithError(err, "datafactory.FactoriesClient", "GetGitHubAccessToken", resp, "Failure responding to request") + } + + return +} + +// GetGitHubAccessTokenPreparer prepares the GetGitHubAccessToken request. +func (client FactoriesClient) GetGitHubAccessTokenPreparer(ctx context.Context, resourceGroupName string, factoryName string, gitHubAccessTokenRequest GitHubAccessTokenRequest) (*http.Request, error) { + pathParameters := map[string]interface{}{ + "factoryName": autorest.Encode("path", factoryName), + "resourceGroupName": autorest.Encode("path", resourceGroupName), + "subscriptionId": autorest.Encode("path", client.SubscriptionID), + } + + const APIVersion = "2018-06-01" + queryParameters := map[string]interface{}{ + "api-version": APIVersion, + } + + preparer := autorest.CreatePreparer( + autorest.AsContentType("application/json; charset=utf-8"), + autorest.AsPost(), + autorest.WithBaseURL(client.BaseURI), + autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/getGitHubAccessToken", pathParameters), + autorest.WithJSON(gitHubAccessTokenRequest), + autorest.WithQueryParameters(queryParameters)) + return preparer.Prepare((&http.Request{}).WithContext(ctx)) +} + +// GetGitHubAccessTokenSender sends the GetGitHubAccessToken request. The method will close the +// http.Response Body if it receives an error. +func (client FactoriesClient) GetGitHubAccessTokenSender(req *http.Request) (*http.Response, error) { + return autorest.SendWithSender(client, req, + azure.DoRetryWithRegistration(client.Client)) +} + +// GetGitHubAccessTokenResponder handles the response to the GetGitHubAccessToken request. The method always +// closes the http.Response Body. +func (client FactoriesClient) GetGitHubAccessTokenResponder(resp *http.Response) (result GitHubAccessTokenResponse, err error) { + err = autorest.Respond( + resp, + client.ByInspecting(), + azure.WithErrorUnlessStatusCode(http.StatusOK), + autorest.ByUnmarshallingJSON(&result), + autorest.ByClosing()) + result.Response = autorest.Response{Response: resp} + return +} + // List lists factories under the specified subscription. func (client FactoriesClient) List(ctx context.Context) (result FactoryListResponsePage, err error) { result.fn = client.listNextResults diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/models.go b/services/datafactory/mgmt/2018-06-01/datafactory/models.go index 7f7e825d65bc..04426e94e627 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/models.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/models.go @@ -1116,6 +1116,8 @@ type TypeBasicActivity string const ( // TypeActivity ... TypeActivity TypeBasicActivity = "Activity" + // TypeAppendVariable ... + TypeAppendVariable TypeBasicActivity = "AppendVariable" // TypeAzureMLBatchExecution ... TypeAzureMLBatchExecution TypeBasicActivity = "AzureMLBatchExecution" // TypeAzureMLUpdateResource ... @@ -1160,6 +1162,8 @@ const ( TypeIfCondition TypeBasicActivity = "IfCondition" // TypeLookup ... TypeLookup TypeBasicActivity = "Lookup" + // TypeSetVariable ... + TypeSetVariable TypeBasicActivity = "SetVariable" // TypeSQLServerStoredProcedure ... TypeSQLServerStoredProcedure TypeBasicActivity = "SqlServerStoredProcedure" // TypeUntil ... @@ -1172,7 +1176,7 @@ const ( // PossibleTypeBasicActivityValues returns an array of possible values for the TypeBasicActivity const type. func PossibleTypeBasicActivityValues() []TypeBasicActivity { - return []TypeBasicActivity{TypeActivity, TypeAzureMLBatchExecution, TypeAzureMLUpdateResource, TypeContainer, TypeCopy, TypeCustom, TypeDatabricksNotebook, TypeDatabricksSparkJar, TypeDatabricksSparkPython, TypeDataLakeAnalyticsUSQL, TypeExecutePipeline, TypeExecuteSSISPackage, TypeExecution, TypeFilter, TypeForEach, TypeGetMetadata, TypeHDInsightHive, TypeHDInsightMapReduce, TypeHDInsightPig, TypeHDInsightSpark, TypeHDInsightStreaming, TypeIfCondition, TypeLookup, TypeSQLServerStoredProcedure, TypeUntil, TypeWait, TypeWebActivity} + return []TypeBasicActivity{TypeActivity, TypeAppendVariable, TypeAzureMLBatchExecution, TypeAzureMLUpdateResource, TypeContainer, TypeCopy, TypeCustom, TypeDatabricksNotebook, TypeDatabricksSparkJar, TypeDatabricksSparkPython, TypeDataLakeAnalyticsUSQL, TypeExecutePipeline, TypeExecuteSSISPackage, TypeExecution, TypeFilter, TypeForEach, TypeGetMetadata, TypeHDInsightHive, TypeHDInsightMapReduce, TypeHDInsightPig, TypeHDInsightSpark, TypeHDInsightStreaming, TypeIfCondition, TypeLookup, TypeSetVariable, TypeSQLServerStoredProcedure, TypeUntil, TypeWait, TypeWebActivity} } // TypeBasicCopySink enumerates the values for type basic copy sink. @@ -1757,6 +1761,23 @@ func PossibleTypeBasicTriggerValues() []TypeBasicTrigger { return []TypeBasicTrigger{TypeBlobEventsTrigger, TypeBlobTrigger, TypeMultiplePipelineTrigger, TypeScheduleTrigger, TypeTrigger, TypeTumblingWindowTrigger} } +// VariableType enumerates the values for variable type. +type VariableType string + +const ( + // VariableTypeArray ... + VariableTypeArray VariableType = "Array" + // VariableTypeBool ... + VariableTypeBool VariableType = "Bool" + // VariableTypeString ... + VariableTypeString VariableType = "String" +) + +// PossibleVariableTypeValues returns an array of possible values for the VariableType const type. +func PossibleVariableTypeValues() []VariableType { + return []VariableType{VariableTypeArray, VariableTypeBool, VariableTypeString} +} + // WebActivityMethod enumerates the values for web activity method. type WebActivityMethod string @@ -1798,6 +1819,8 @@ type BasicActivity interface { AsCopyActivity() (*CopyActivity, bool) AsExecutionActivity() (*ExecutionActivity, bool) AsBasicExecutionActivity() (BasicExecutionActivity, bool) + AsAppendVariableActivity() (*AppendVariableActivity, bool) + AsSetVariableActivity() (*SetVariableActivity, bool) AsFilterActivity() (*FilterActivity, bool) AsUntilActivity() (*UntilActivity, bool) AsWaitActivity() (*WaitActivity, bool) @@ -1821,7 +1844,7 @@ type Activity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -1909,6 +1932,14 @@ func unmarshalBasicActivity(body []byte) (BasicActivity, error) { var ea ExecutionActivity err := json.Unmarshal(body, &ea) return ea, err + case string(TypeAppendVariable): + var ava AppendVariableActivity + err := json.Unmarshal(body, &ava) + return ava, err + case string(TypeSetVariable): + var sva SetVariableActivity + err := json.Unmarshal(body, &sva) + return sva, err case string(TypeFilter): var fa FilterActivity err := json.Unmarshal(body, &fa) @@ -2087,6 +2118,16 @@ func (a Activity) AsBasicExecutionActivity() (BasicExecutionActivity, bool) { return nil, false } +// AsAppendVariableActivity is the BasicActivity implementation for Activity. +func (a Activity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for Activity. +func (a Activity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for Activity. func (a Activity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -2172,6 +2213,8 @@ type ActivityPolicy struct { Retry interface{} `json:"retry,omitempty"` // RetryIntervalInSeconds - Interval between each retry attempt (in seconds). The default is 30 sec. RetryIntervalInSeconds *int32 `json:"retryIntervalInSeconds,omitempty"` + // SecureInput - When set to true, input from activity is considered as secure and will not be logged to monitoring. + SecureInput *bool `json:"secureInput,omitempty"` // SecureOutput - When set to true, Output from activity is considered as secure and will not be logged to monitoring. SecureOutput *bool `json:"secureOutput,omitempty"` } @@ -2184,6 +2227,9 @@ func (ap ActivityPolicy) MarshalJSON() ([]byte, error) { if ap.RetryIntervalInSeconds != nil { objectMap["retryIntervalInSeconds"] = ap.RetryIntervalInSeconds } + if ap.SecureInput != nil { + objectMap["secureInput"] = ap.SecureInput + } if ap.SecureOutput != nil { objectMap["secureOutput"] = ap.SecureOutput } @@ -5449,6 +5495,301 @@ func (aslstp *AmazonS3LinkedServiceTypeProperties) UnmarshalJSON(body []byte) er return nil } +// AppendVariableActivity append value to a array Variable. +type AppendVariableActivity struct { + // AppendVariableActivityTypeProperties - Append Variable activity properties. + *AppendVariableActivityTypeProperties `json:"typeProperties,omitempty"` + // AdditionalProperties - Unmatched properties from the message are deserialized this collection + AdditionalProperties map[string]interface{} `json:""` + // Name - Activity name. + Name *string `json:"name,omitempty"` + // Description - Activity description. + Description *string `json:"description,omitempty"` + // DependsOn - Activity depends on condition. + DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` + // UserProperties - Activity user properties. + UserProperties *[]UserProperty `json:"userProperties,omitempty"` + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + Type TypeBasicActivity `json:"type,omitempty"` +} + +// MarshalJSON is the custom marshaler for AppendVariableActivity. +func (ava AppendVariableActivity) MarshalJSON() ([]byte, error) { + ava.Type = TypeAppendVariable + objectMap := make(map[string]interface{}) + if ava.AppendVariableActivityTypeProperties != nil { + objectMap["typeProperties"] = ava.AppendVariableActivityTypeProperties + } + if ava.Name != nil { + objectMap["name"] = ava.Name + } + if ava.Description != nil { + objectMap["description"] = ava.Description + } + if ava.DependsOn != nil { + objectMap["dependsOn"] = ava.DependsOn + } + if ava.UserProperties != nil { + objectMap["userProperties"] = ava.UserProperties + } + if ava.Type != "" { + objectMap["type"] = ava.Type + } + for k, v := range ava.AdditionalProperties { + objectMap[k] = v + } + return json.Marshal(objectMap) +} + +// AsDatabricksSparkPythonActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsDatabricksSparkPythonActivity() (*DatabricksSparkPythonActivity, bool) { + return nil, false +} + +// AsDatabricksSparkJarActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsDatabricksSparkJarActivity() (*DatabricksSparkJarActivity, bool) { + return nil, false +} + +// AsDatabricksNotebookActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsDatabricksNotebookActivity() (*DatabricksNotebookActivity, bool) { + return nil, false +} + +// AsDataLakeAnalyticsUSQLActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsDataLakeAnalyticsUSQLActivity() (*DataLakeAnalyticsUSQLActivity, bool) { + return nil, false +} + +// AsAzureMLUpdateResourceActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsAzureMLUpdateResourceActivity() (*AzureMLUpdateResourceActivity, bool) { + return nil, false +} + +// AsAzureMLBatchExecutionActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsAzureMLBatchExecutionActivity() (*AzureMLBatchExecutionActivity, bool) { + return nil, false +} + +// AsGetMetadataActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsGetMetadataActivity() (*GetMetadataActivity, bool) { + return nil, false +} + +// AsWebActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsWebActivity() (*WebActivity, bool) { + return nil, false +} + +// AsLookupActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsLookupActivity() (*LookupActivity, bool) { + return nil, false +} + +// AsSQLServerStoredProcedureActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsSQLServerStoredProcedureActivity() (*SQLServerStoredProcedureActivity, bool) { + return nil, false +} + +// AsCustomActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsCustomActivity() (*CustomActivity, bool) { + return nil, false +} + +// AsExecuteSSISPackageActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsExecuteSSISPackageActivity() (*ExecuteSSISPackageActivity, bool) { + return nil, false +} + +// AsHDInsightSparkActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsHDInsightSparkActivity() (*HDInsightSparkActivity, bool) { + return nil, false +} + +// AsHDInsightStreamingActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsHDInsightStreamingActivity() (*HDInsightStreamingActivity, bool) { + return nil, false +} + +// AsHDInsightMapReduceActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsHDInsightMapReduceActivity() (*HDInsightMapReduceActivity, bool) { + return nil, false +} + +// AsHDInsightPigActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsHDInsightPigActivity() (*HDInsightPigActivity, bool) { + return nil, false +} + +// AsHDInsightHiveActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsHDInsightHiveActivity() (*HDInsightHiveActivity, bool) { + return nil, false +} + +// AsCopyActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsCopyActivity() (*CopyActivity, bool) { + return nil, false +} + +// AsExecutionActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsExecutionActivity() (*ExecutionActivity, bool) { + return nil, false +} + +// AsBasicExecutionActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsBasicExecutionActivity() (BasicExecutionActivity, bool) { + return nil, false +} + +// AsAppendVariableActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return &ava, true +} + +// AsSetVariableActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + +// AsFilterActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsFilterActivity() (*FilterActivity, bool) { + return nil, false +} + +// AsUntilActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsUntilActivity() (*UntilActivity, bool) { + return nil, false +} + +// AsWaitActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsWaitActivity() (*WaitActivity, bool) { + return nil, false +} + +// AsForEachActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsForEachActivity() (*ForEachActivity, bool) { + return nil, false +} + +// AsIfConditionActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsIfConditionActivity() (*IfConditionActivity, bool) { + return nil, false +} + +// AsExecutePipelineActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsExecutePipelineActivity() (*ExecutePipelineActivity, bool) { + return nil, false +} + +// AsControlActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsControlActivity() (*ControlActivity, bool) { + return nil, false +} + +// AsBasicControlActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsBasicControlActivity() (BasicControlActivity, bool) { + return &ava, true +} + +// AsActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsActivity() (*Activity, bool) { + return nil, false +} + +// AsBasicActivity is the BasicActivity implementation for AppendVariableActivity. +func (ava AppendVariableActivity) AsBasicActivity() (BasicActivity, bool) { + return &ava, true +} + +// UnmarshalJSON is the custom unmarshaler for AppendVariableActivity struct. +func (ava *AppendVariableActivity) UnmarshalJSON(body []byte) error { + var m map[string]*json.RawMessage + err := json.Unmarshal(body, &m) + if err != nil { + return err + } + for k, v := range m { + switch k { + case "typeProperties": + if v != nil { + var appendVariableActivityTypeProperties AppendVariableActivityTypeProperties + err = json.Unmarshal(*v, &appendVariableActivityTypeProperties) + if err != nil { + return err + } + ava.AppendVariableActivityTypeProperties = &appendVariableActivityTypeProperties + } + default: + if v != nil { + var additionalProperties interface{} + err = json.Unmarshal(*v, &additionalProperties) + if err != nil { + return err + } + if ava.AdditionalProperties == nil { + ava.AdditionalProperties = make(map[string]interface{}) + } + ava.AdditionalProperties[k] = additionalProperties + } + case "name": + if v != nil { + var name string + err = json.Unmarshal(*v, &name) + if err != nil { + return err + } + ava.Name = &name + } + case "description": + if v != nil { + var description string + err = json.Unmarshal(*v, &description) + if err != nil { + return err + } + ava.Description = &description + } + case "dependsOn": + if v != nil { + var dependsOn []ActivityDependency + err = json.Unmarshal(*v, &dependsOn) + if err != nil { + return err + } + ava.DependsOn = &dependsOn + } + case "userProperties": + if v != nil { + var userProperties []UserProperty + err = json.Unmarshal(*v, &userProperties) + if err != nil { + return err + } + ava.UserProperties = &userProperties + } + case "type": + if v != nil { + var typeVar TypeBasicActivity + err = json.Unmarshal(*v, &typeVar) + if err != nil { + return err + } + ava.Type = typeVar + } + } + } + + return nil +} + +// AppendVariableActivityTypeProperties appendVariable activity properties. +type AppendVariableActivityTypeProperties struct { + // Name - Name of the variable to which value needs to be appended. + Name *string `json:"name,omitempty"` + // Value - Value to be appended. Could be a static value or Expression + Value interface{} `json:"value,omitempty"` +} + // AvroFormat the data stored in Avro format. type AvroFormat struct { // AdditionalProperties - Unmatched properties from the message are deserialized this collection @@ -7694,8 +8035,10 @@ type AzureDatabricksLinkedServiceTypeProperties struct { NewClusterNumOfWorker interface{} `json:"newClusterNumOfWorker,omitempty"` // NewClusterNodeType - The node types of new cluster. Type: string (or Expression with resultType string). NewClusterNodeType interface{} `json:"newClusterNodeType,omitempty"` - // NewClusterSparkConf - a set of optional, user-specified Spark configuration key-value pairs. + // NewClusterSparkConf - A set of optional, user-specified Spark configuration key-value pairs. NewClusterSparkConf map[string]interface{} `json:"newClusterSparkConf"` + // NewClusterSparkEnvVars - A set of optional, user-specified Spark environment variables key-value pairs. + NewClusterSparkEnvVars map[string]interface{} `json:"newClusterSparkEnvVars"` // NewClusterCustomTags - Additional tags for cluster resources. NewClusterCustomTags map[string]interface{} `json:"newClusterCustomTags"` // EncryptedCredential - The encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string (or Expression with resultType string). @@ -7714,6 +8057,9 @@ func (adlstp AzureDatabricksLinkedServiceTypeProperties) MarshalJSON() ([]byte, if adlstp.NewClusterSparkConf != nil { objectMap["newClusterSparkConf"] = adlstp.NewClusterSparkConf } + if adlstp.NewClusterSparkEnvVars != nil { + objectMap["newClusterSparkEnvVars"] = adlstp.NewClusterSparkEnvVars + } if adlstp.NewClusterCustomTags != nil { objectMap["newClusterCustomTags"] = adlstp.NewClusterCustomTags } @@ -7792,6 +8138,15 @@ func (adlstp *AzureDatabricksLinkedServiceTypeProperties) UnmarshalJSON(body []b } adlstp.NewClusterSparkConf = newClusterSparkConf } + case "newClusterSparkEnvVars": + if v != nil { + var newClusterSparkEnvVars map[string]interface{} + err = json.Unmarshal(*v, &newClusterSparkEnvVars) + if err != nil { + return err + } + adlstp.NewClusterSparkEnvVars = newClusterSparkEnvVars + } case "newClusterCustomTags": if v != nil { var newClusterCustomTags map[string]interface{} @@ -10487,7 +10842,7 @@ type AzureMLBatchExecutionActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -10625,6 +10980,16 @@ func (ambea AzureMLBatchExecutionActivity) AsBasicExecutionActivity() (BasicExec return &ambea, true } +// AsAppendVariableActivity is the BasicActivity implementation for AzureMLBatchExecutionActivity. +func (ambea AzureMLBatchExecutionActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for AzureMLBatchExecutionActivity. +func (ambea AzureMLBatchExecutionActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for AzureMLBatchExecutionActivity. func (ambea AzureMLBatchExecutionActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -11408,7 +11773,7 @@ type AzureMLUpdateResourceActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -11546,6 +11911,16 @@ func (amura AzureMLUpdateResourceActivity) AsBasicExecutionActivity() (BasicExec return &amura, true } +// AsAppendVariableActivity is the BasicActivity implementation for AzureMLUpdateResourceActivity. +func (amura AzureMLUpdateResourceActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for AzureMLUpdateResourceActivity. +func (amura AzureMLUpdateResourceActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for AzureMLUpdateResourceActivity. func (amura AzureMLUpdateResourceActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -22501,6 +22876,8 @@ func (cs ConcurSource) AsBasicCopySource() (BasicCopySource, bool) { // BasicControlActivity base class for all control activities like IfCondition, ForEach , Until. type BasicControlActivity interface { + AsAppendVariableActivity() (*AppendVariableActivity, bool) + AsSetVariableActivity() (*SetVariableActivity, bool) AsFilterActivity() (*FilterActivity, bool) AsUntilActivity() (*UntilActivity, bool) AsWaitActivity() (*WaitActivity, bool) @@ -22522,7 +22899,7 @@ type ControlActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -22534,6 +22911,14 @@ func unmarshalBasicControlActivity(body []byte) (BasicControlActivity, error) { } switch m["type"] { + case string(TypeAppendVariable): + var ava AppendVariableActivity + err := json.Unmarshal(body, &ava) + return ava, err + case string(TypeSetVariable): + var sva SetVariableActivity + err := json.Unmarshal(body, &sva) + return sva, err case string(TypeFilter): var fa FilterActivity err := json.Unmarshal(body, &fa) @@ -22708,6 +23093,16 @@ func (ca ControlActivity) AsBasicExecutionActivity() (BasicExecutionActivity, bo return nil, false } +// AsAppendVariableActivity is the BasicActivity implementation for ControlActivity. +func (ca ControlActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for ControlActivity. +func (ca ControlActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for ControlActivity. func (ca ControlActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -22780,7 +23175,7 @@ type CopyActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -22924,6 +23319,16 @@ func (ca CopyActivity) AsBasicExecutionActivity() (BasicExecutionActivity, bool) return &ca, true } +// AsAppendVariableActivity is the BasicActivity implementation for CopyActivity. +func (ca CopyActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for CopyActivity. +func (ca CopyActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for CopyActivity. func (ca CopyActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -25742,7 +26147,7 @@ type CustomActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -25880,6 +26285,16 @@ func (ca CustomActivity) AsBasicExecutionActivity() (BasicExecutionActivity, boo return &ca, true } +// AsAppendVariableActivity is the BasicActivity implementation for CustomActivity. +func (ca CustomActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for CustomActivity. +func (ca CustomActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for CustomActivity. func (ca CustomActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -26827,7 +27242,7 @@ type DatabricksNotebookActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -26965,6 +27380,16 @@ func (dna DatabricksNotebookActivity) AsBasicExecutionActivity() (BasicExecution return &dna, true } +// AsAppendVariableActivity is the BasicActivity implementation for DatabricksNotebookActivity. +func (dna DatabricksNotebookActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for DatabricksNotebookActivity. +func (dna DatabricksNotebookActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for DatabricksNotebookActivity. func (dna DatabricksNotebookActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -27155,7 +27580,7 @@ type DatabricksSparkJarActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -27293,6 +27718,16 @@ func (dsja DatabricksSparkJarActivity) AsBasicExecutionActivity() (BasicExecutio return &dsja, true } +// AsAppendVariableActivity is the BasicActivity implementation for DatabricksSparkJarActivity. +func (dsja DatabricksSparkJarActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for DatabricksSparkJarActivity. +func (dsja DatabricksSparkJarActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for DatabricksSparkJarActivity. func (dsja DatabricksSparkJarActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -27470,7 +27905,7 @@ type DatabricksSparkPythonActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -27608,6 +28043,16 @@ func (dspa DatabricksSparkPythonActivity) AsBasicExecutionActivity() (BasicExecu return &dspa, true } +// AsAppendVariableActivity is the BasicActivity implementation for DatabricksSparkPythonActivity. +func (dspa DatabricksSparkPythonActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for DatabricksSparkPythonActivity. +func (dspa DatabricksSparkPythonActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for DatabricksSparkPythonActivity. func (dspa DatabricksSparkPythonActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -27785,7 +28230,7 @@ type DataLakeAnalyticsUSQLActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -27923,6 +28368,16 @@ func (dlaua DataLakeAnalyticsUSQLActivity) AsBasicExecutionActivity() (BasicExec return &dlaua, true } +// AsAppendVariableActivity is the BasicActivity implementation for DataLakeAnalyticsUSQLActivity. +func (dlaua DataLakeAnalyticsUSQLActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for DataLakeAnalyticsUSQLActivity. +func (dlaua DataLakeAnalyticsUSQLActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for DataLakeAnalyticsUSQLActivity. func (dlaua DataLakeAnalyticsUSQLActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -34728,7 +35183,7 @@ type ExecutePipelineActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -34860,6 +35315,16 @@ func (epa ExecutePipelineActivity) AsBasicExecutionActivity() (BasicExecutionAct return nil, false } +// AsAppendVariableActivity is the BasicActivity implementation for ExecutePipelineActivity. +func (epa ExecutePipelineActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for ExecutePipelineActivity. +func (epa ExecutePipelineActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for ExecutePipelineActivity. func (epa ExecutePipelineActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -35034,7 +35499,7 @@ type ExecuteSSISPackageActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -35172,6 +35637,16 @@ func (espa ExecuteSSISPackageActivity) AsBasicExecutionActivity() (BasicExecutio return &espa, true } +// AsAppendVariableActivity is the BasicActivity implementation for ExecuteSSISPackageActivity. +func (espa ExecuteSSISPackageActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for ExecuteSSISPackageActivity. +func (espa ExecuteSSISPackageActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for ExecuteSSISPackageActivity. func (espa ExecuteSSISPackageActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -35420,7 +35895,7 @@ type ExecutionActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -35660,6 +36135,16 @@ func (ea ExecutionActivity) AsBasicExecutionActivity() (BasicExecutionActivity, return &ea, true } +// AsAppendVariableActivity is the BasicActivity implementation for ExecutionActivity. +func (ea ExecutionActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for ExecutionActivity. +func (ea ExecutionActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for ExecutionActivity. func (ea ExecutionActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -37834,7 +38319,7 @@ type FilterActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -37966,6 +38451,16 @@ func (fa FilterActivity) AsBasicExecutionActivity() (BasicExecutionActivity, boo return nil, false } +// AsAppendVariableActivity is the BasicActivity implementation for FilterActivity. +func (fa FilterActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for FilterActivity. +func (fa FilterActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for FilterActivity. func (fa FilterActivity) AsFilterActivity() (*FilterActivity, bool) { return &fa, true @@ -38097,7 +38592,7 @@ func (fa *FilterActivity) UnmarshalJSON(body []byte) error { return nil } -// FilterActivityTypeProperties fitler activity properties. +// FilterActivityTypeProperties filter activity properties. type FilterActivityTypeProperties struct { // Items - Input array on which filter should be applied. Items *Expression `json:"items,omitempty"` @@ -38119,7 +38614,7 @@ type ForEachActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -38251,6 +38746,16 @@ func (fea ForEachActivity) AsBasicExecutionActivity() (BasicExecutionActivity, b return nil, false } +// AsAppendVariableActivity is the BasicActivity implementation for ForEachActivity. +func (fea ForEachActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for ForEachActivity. +func (fea ForEachActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for ForEachActivity. func (fea ForEachActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -39065,7 +39570,7 @@ type GetMetadataActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -39203,6 +39708,16 @@ func (gma GetMetadataActivity) AsBasicExecutionActivity() (BasicExecutionActivit return &gma, true } +// AsAppendVariableActivity is the BasicActivity implementation for GetMetadataActivity. +func (gma GetMetadataActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for GetMetadataActivity. +func (gma GetMetadataActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for GetMetadataActivity. func (gma GetMetadataActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -39360,6 +39875,23 @@ type GetMetadataActivityTypeProperties struct { FieldList *[]interface{} `json:"fieldList,omitempty"` } +// GitHubAccessTokenRequest get GitHub access token request definition. +type GitHubAccessTokenRequest struct { + // GitHubAccessCode - GitHub access code. + GitHubAccessCode *string `json:"gitHubAccessCode,omitempty"` + // GitHubClientID - GitHub application client ID. + GitHubClientID *string `json:"gitHubClientId,omitempty"` + // GitHubAccessTokenBaseURL - GitHub access token base URL. + GitHubAccessTokenBaseURL *string `json:"gitHubAccessTokenBaseUrl,omitempty"` +} + +// GitHubAccessTokenResponse get GitHub access token response definition. +type GitHubAccessTokenResponse struct { + autorest.Response `json:"-"` + // GitHubAccessToken - GitHub access token. + GitHubAccessToken *string `json:"gitHubAccessToken,omitempty"` +} + // GoogleBigQueryLinkedService google BigQuery service linked service. type GoogleBigQueryLinkedService struct { // GoogleBigQueryLinkedServiceTypeProperties - Google BigQuery service linked service properties. @@ -43871,7 +44403,7 @@ type HDInsightHiveActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -44009,6 +44541,16 @@ func (hiha HDInsightHiveActivity) AsBasicExecutionActivity() (BasicExecutionActi return &hiha, true } +// AsAppendVariableActivity is the BasicActivity implementation for HDInsightHiveActivity. +func (hiha HDInsightHiveActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for HDInsightHiveActivity. +func (hiha HDInsightHiveActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for HDInsightHiveActivity. func (hiha HDInsightHiveActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -44795,7 +45337,7 @@ type HDInsightMapReduceActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -44933,6 +45475,16 @@ func (himra HDInsightMapReduceActivity) AsBasicExecutionActivity() (BasicExecuti return &himra, true } +// AsAppendVariableActivity is the BasicActivity implementation for HDInsightMapReduceActivity. +func (himra HDInsightMapReduceActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for HDInsightMapReduceActivity. +func (himra HDInsightMapReduceActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for HDInsightMapReduceActivity. func (himra HDInsightMapReduceActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -45989,7 +46541,7 @@ type HDInsightPigActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -46127,6 +46679,16 @@ func (hipa HDInsightPigActivity) AsBasicExecutionActivity() (BasicExecutionActiv return &hipa, true } +// AsAppendVariableActivity is the BasicActivity implementation for HDInsightPigActivity. +func (hipa HDInsightPigActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for HDInsightPigActivity. +func (hipa HDInsightPigActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for HDInsightPigActivity. func (hipa HDInsightPigActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -46332,7 +46894,7 @@ type HDInsightSparkActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -46470,6 +47032,16 @@ func (hisa HDInsightSparkActivity) AsBasicExecutionActivity() (BasicExecutionAct return &hisa, true } +// AsAppendVariableActivity is the BasicActivity implementation for HDInsightSparkActivity. +func (hisa HDInsightSparkActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for HDInsightSparkActivity. +func (hisa HDInsightSparkActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for HDInsightSparkActivity. func (hisa HDInsightSparkActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -46681,7 +47253,7 @@ type HDInsightStreamingActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -46819,6 +47391,16 @@ func (hisa HDInsightStreamingActivity) AsBasicExecutionActivity() (BasicExecutio return &hisa, true } +// AsAppendVariableActivity is the BasicActivity implementation for HDInsightStreamingActivity. +func (hisa HDInsightStreamingActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for HDInsightStreamingActivity. +func (hisa HDInsightStreamingActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for HDInsightStreamingActivity. func (hisa HDInsightStreamingActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -50980,7 +51562,7 @@ type IfConditionActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -51112,6 +51694,16 @@ func (ica IfConditionActivity) AsBasicExecutionActivity() (BasicExecutionActivit return nil, false } +// AsAppendVariableActivity is the BasicActivity implementation for IfConditionActivity. +func (ica IfConditionActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for IfConditionActivity. +func (ica IfConditionActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for IfConditionActivity. func (ica IfConditionActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -55828,7 +56420,7 @@ type LookupActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -55966,6 +56558,16 @@ func (la LookupActivity) AsBasicExecutionActivity() (BasicExecutionActivity, boo return &la, true } +// AsAppendVariableActivity is the BasicActivity implementation for LookupActivity. +func (la LookupActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for LookupActivity. +func (la LookupActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for LookupActivity. func (la LookupActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -69033,6 +69635,8 @@ type Pipeline struct { Activities *[]BasicActivity `json:"activities,omitempty"` // Parameters - List of parameters for pipeline. Parameters map[string]*ParameterSpecification `json:"parameters"` + // Variables - List of variables for pipeline. + Variables map[string]*VariableSpecification `json:"variables"` // Concurrency - The max number of concurrent runs for the pipeline. Concurrency *int32 `json:"concurrency,omitempty"` // Annotations - List of tags that can be used for describing the Pipeline. @@ -69053,6 +69657,9 @@ func (p Pipeline) MarshalJSON() ([]byte, error) { if p.Parameters != nil { objectMap["parameters"] = p.Parameters } + if p.Variables != nil { + objectMap["variables"] = p.Variables + } if p.Concurrency != nil { objectMap["concurrency"] = p.Concurrency } @@ -69100,6 +69707,15 @@ func (p *Pipeline) UnmarshalJSON(body []byte) error { } p.Parameters = parameters } + case "variables": + if v != nil { + var variables map[string]*VariableSpecification + err = json.Unmarshal(*v, &variables) + if err != nil { + return err + } + p.Variables = variables + } case "concurrency": if v != nil { var concurrency int32 @@ -83140,6 +83756,301 @@ func (sns ServiceNowSource) AsBasicCopySource() (BasicCopySource, bool) { return &sns, true } +// SetVariableActivity set value for a Variable. +type SetVariableActivity struct { + // SetVariableActivityTypeProperties - Set Variable activity properties. + *SetVariableActivityTypeProperties `json:"typeProperties,omitempty"` + // AdditionalProperties - Unmatched properties from the message are deserialized this collection + AdditionalProperties map[string]interface{} `json:""` + // Name - Activity name. + Name *string `json:"name,omitempty"` + // Description - Activity description. + Description *string `json:"description,omitempty"` + // DependsOn - Activity depends on condition. + DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` + // UserProperties - Activity user properties. + UserProperties *[]UserProperty `json:"userProperties,omitempty"` + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + Type TypeBasicActivity `json:"type,omitempty"` +} + +// MarshalJSON is the custom marshaler for SetVariableActivity. +func (sva SetVariableActivity) MarshalJSON() ([]byte, error) { + sva.Type = TypeSetVariable + objectMap := make(map[string]interface{}) + if sva.SetVariableActivityTypeProperties != nil { + objectMap["typeProperties"] = sva.SetVariableActivityTypeProperties + } + if sva.Name != nil { + objectMap["name"] = sva.Name + } + if sva.Description != nil { + objectMap["description"] = sva.Description + } + if sva.DependsOn != nil { + objectMap["dependsOn"] = sva.DependsOn + } + if sva.UserProperties != nil { + objectMap["userProperties"] = sva.UserProperties + } + if sva.Type != "" { + objectMap["type"] = sva.Type + } + for k, v := range sva.AdditionalProperties { + objectMap[k] = v + } + return json.Marshal(objectMap) +} + +// AsDatabricksSparkPythonActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsDatabricksSparkPythonActivity() (*DatabricksSparkPythonActivity, bool) { + return nil, false +} + +// AsDatabricksSparkJarActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsDatabricksSparkJarActivity() (*DatabricksSparkJarActivity, bool) { + return nil, false +} + +// AsDatabricksNotebookActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsDatabricksNotebookActivity() (*DatabricksNotebookActivity, bool) { + return nil, false +} + +// AsDataLakeAnalyticsUSQLActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsDataLakeAnalyticsUSQLActivity() (*DataLakeAnalyticsUSQLActivity, bool) { + return nil, false +} + +// AsAzureMLUpdateResourceActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsAzureMLUpdateResourceActivity() (*AzureMLUpdateResourceActivity, bool) { + return nil, false +} + +// AsAzureMLBatchExecutionActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsAzureMLBatchExecutionActivity() (*AzureMLBatchExecutionActivity, bool) { + return nil, false +} + +// AsGetMetadataActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsGetMetadataActivity() (*GetMetadataActivity, bool) { + return nil, false +} + +// AsWebActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsWebActivity() (*WebActivity, bool) { + return nil, false +} + +// AsLookupActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsLookupActivity() (*LookupActivity, bool) { + return nil, false +} + +// AsSQLServerStoredProcedureActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsSQLServerStoredProcedureActivity() (*SQLServerStoredProcedureActivity, bool) { + return nil, false +} + +// AsCustomActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsCustomActivity() (*CustomActivity, bool) { + return nil, false +} + +// AsExecuteSSISPackageActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsExecuteSSISPackageActivity() (*ExecuteSSISPackageActivity, bool) { + return nil, false +} + +// AsHDInsightSparkActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsHDInsightSparkActivity() (*HDInsightSparkActivity, bool) { + return nil, false +} + +// AsHDInsightStreamingActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsHDInsightStreamingActivity() (*HDInsightStreamingActivity, bool) { + return nil, false +} + +// AsHDInsightMapReduceActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsHDInsightMapReduceActivity() (*HDInsightMapReduceActivity, bool) { + return nil, false +} + +// AsHDInsightPigActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsHDInsightPigActivity() (*HDInsightPigActivity, bool) { + return nil, false +} + +// AsHDInsightHiveActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsHDInsightHiveActivity() (*HDInsightHiveActivity, bool) { + return nil, false +} + +// AsCopyActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsCopyActivity() (*CopyActivity, bool) { + return nil, false +} + +// AsExecutionActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsExecutionActivity() (*ExecutionActivity, bool) { + return nil, false +} + +// AsBasicExecutionActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsBasicExecutionActivity() (BasicExecutionActivity, bool) { + return nil, false +} + +// AsAppendVariableActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return &sva, true +} + +// AsFilterActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsFilterActivity() (*FilterActivity, bool) { + return nil, false +} + +// AsUntilActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsUntilActivity() (*UntilActivity, bool) { + return nil, false +} + +// AsWaitActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsWaitActivity() (*WaitActivity, bool) { + return nil, false +} + +// AsForEachActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsForEachActivity() (*ForEachActivity, bool) { + return nil, false +} + +// AsIfConditionActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsIfConditionActivity() (*IfConditionActivity, bool) { + return nil, false +} + +// AsExecutePipelineActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsExecutePipelineActivity() (*ExecutePipelineActivity, bool) { + return nil, false +} + +// AsControlActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsControlActivity() (*ControlActivity, bool) { + return nil, false +} + +// AsBasicControlActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsBasicControlActivity() (BasicControlActivity, bool) { + return &sva, true +} + +// AsActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsActivity() (*Activity, bool) { + return nil, false +} + +// AsBasicActivity is the BasicActivity implementation for SetVariableActivity. +func (sva SetVariableActivity) AsBasicActivity() (BasicActivity, bool) { + return &sva, true +} + +// UnmarshalJSON is the custom unmarshaler for SetVariableActivity struct. +func (sva *SetVariableActivity) UnmarshalJSON(body []byte) error { + var m map[string]*json.RawMessage + err := json.Unmarshal(body, &m) + if err != nil { + return err + } + for k, v := range m { + switch k { + case "typeProperties": + if v != nil { + var setVariableActivityTypeProperties SetVariableActivityTypeProperties + err = json.Unmarshal(*v, &setVariableActivityTypeProperties) + if err != nil { + return err + } + sva.SetVariableActivityTypeProperties = &setVariableActivityTypeProperties + } + default: + if v != nil { + var additionalProperties interface{} + err = json.Unmarshal(*v, &additionalProperties) + if err != nil { + return err + } + if sva.AdditionalProperties == nil { + sva.AdditionalProperties = make(map[string]interface{}) + } + sva.AdditionalProperties[k] = additionalProperties + } + case "name": + if v != nil { + var name string + err = json.Unmarshal(*v, &name) + if err != nil { + return err + } + sva.Name = &name + } + case "description": + if v != nil { + var description string + err = json.Unmarshal(*v, &description) + if err != nil { + return err + } + sva.Description = &description + } + case "dependsOn": + if v != nil { + var dependsOn []ActivityDependency + err = json.Unmarshal(*v, &dependsOn) + if err != nil { + return err + } + sva.DependsOn = &dependsOn + } + case "userProperties": + if v != nil { + var userProperties []UserProperty + err = json.Unmarshal(*v, &userProperties) + if err != nil { + return err + } + sva.UserProperties = &userProperties + } + case "type": + if v != nil { + var typeVar TypeBasicActivity + err = json.Unmarshal(*v, &typeVar) + if err != nil { + return err + } + sva.Type = typeVar + } + } + } + + return nil +} + +// SetVariableActivityTypeProperties setVariable activity properties. +type SetVariableActivityTypeProperties struct { + // Name - Name of the variable whose value needs to be set. + Name *string `json:"name,omitempty"` + // Value - Value to be set. Could be a static value or Expression + Value interface{} `json:"value,omitempty"` +} + // SftpServerLinkedService a linked service for an SSH File Transfer Protocol (SFTP) server. type SftpServerLinkedService struct { // SftpServerLinkedServiceTypeProperties - Properties specific to this linked service type. @@ -87249,7 +88160,7 @@ type SQLServerStoredProcedureActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -87387,6 +88298,16 @@ func (ssspa SQLServerStoredProcedureActivity) AsBasicExecutionActivity() (BasicE return &ssspa, true } +// AsAppendVariableActivity is the BasicActivity implementation for SQLServerStoredProcedureActivity. +func (ssspa SQLServerStoredProcedureActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for SQLServerStoredProcedureActivity. +func (ssspa SQLServerStoredProcedureActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for SQLServerStoredProcedureActivity. func (ssspa SQLServerStoredProcedureActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -91866,7 +92787,7 @@ type UntilActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -91998,6 +92919,16 @@ func (ua UntilActivity) AsBasicExecutionActivity() (BasicExecutionActivity, bool return nil, false } +// AsAppendVariableActivity is the BasicActivity implementation for UntilActivity. +func (ua UntilActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for UntilActivity. +func (ua UntilActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for UntilActivity. func (ua UntilActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -92202,6 +93133,14 @@ type UserProperty struct { Value interface{} `json:"value,omitempty"` } +// VariableSpecification definition of a single variable for an pipeline. +type VariableSpecification struct { + // Type - Variable type. Possible values include: 'VariableTypeString', 'VariableTypeBool', 'VariableTypeArray' + Type VariableType `json:"type,omitempty"` + // DefaultValue - Default value of variable. + DefaultValue interface{} `json:"defaultValue,omitempty"` +} + // VerticaLinkedService vertica linked service. type VerticaLinkedService struct { // VerticaLinkedServiceTypeProperties - Vertica linked service properties. @@ -93335,7 +94274,7 @@ type WaitActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -93467,6 +94406,16 @@ func (wa WaitActivity) AsBasicExecutionActivity() (BasicExecutionActivity, bool) return nil, false } +// AsAppendVariableActivity is the BasicActivity implementation for WaitActivity. +func (wa WaitActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for WaitActivity. +func (wa WaitActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for WaitActivity. func (wa WaitActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false @@ -93622,7 +94571,7 @@ type WebActivity struct { DependsOn *[]ActivityDependency `json:"dependsOn,omitempty"` // UserProperties - Activity user properties. UserProperties *[]UserProperty `json:"userProperties,omitempty"` - // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' + // Type - Possible values include: 'TypeActivity', 'TypeDatabricksSparkPython', 'TypeDatabricksSparkJar', 'TypeDatabricksNotebook', 'TypeDataLakeAnalyticsUSQL', 'TypeAzureMLUpdateResource', 'TypeAzureMLBatchExecution', 'TypeGetMetadata', 'TypeWebActivity', 'TypeLookup', 'TypeSQLServerStoredProcedure', 'TypeCustom', 'TypeExecuteSSISPackage', 'TypeHDInsightSpark', 'TypeHDInsightStreaming', 'TypeHDInsightMapReduce', 'TypeHDInsightPig', 'TypeHDInsightHive', 'TypeCopy', 'TypeExecution', 'TypeAppendVariable', 'TypeSetVariable', 'TypeFilter', 'TypeUntil', 'TypeWait', 'TypeForEach', 'TypeIfCondition', 'TypeExecutePipeline', 'TypeContainer' Type TypeBasicActivity `json:"type,omitempty"` } @@ -93760,6 +94709,16 @@ func (wa WebActivity) AsBasicExecutionActivity() (BasicExecutionActivity, bool) return &wa, true } +// AsAppendVariableActivity is the BasicActivity implementation for WebActivity. +func (wa WebActivity) AsAppendVariableActivity() (*AppendVariableActivity, bool) { + return nil, false +} + +// AsSetVariableActivity is the BasicActivity implementation for WebActivity. +func (wa WebActivity) AsSetVariableActivity() (*SetVariableActivity, bool) { + return nil, false +} + // AsFilterActivity is the BasicActivity implementation for WebActivity. func (wa WebActivity) AsFilterActivity() (*FilterActivity, bool) { return nil, false diff --git a/services/datafactory/mgmt/2018-06-01/datafactory/pipelineruns.go b/services/datafactory/mgmt/2018-06-01/datafactory/pipelineruns.go index 5c4057cca6b5..97480a527509 100644 --- a/services/datafactory/mgmt/2018-06-01/datafactory/pipelineruns.go +++ b/services/datafactory/mgmt/2018-06-01/datafactory/pipelineruns.go @@ -46,7 +46,8 @@ func NewPipelineRunsClientWithBaseURI(baseURI string, subscriptionID string) Pip // resourceGroupName - the resource group name. // factoryName - the factory name. // runID - the pipeline run identifier. -func (client PipelineRunsClient) Cancel(ctx context.Context, resourceGroupName string, factoryName string, runID string) (result autorest.Response, err error) { +// isRecursive - if true, cancel all the Child pipelines that are triggered by the current pipeline. +func (client PipelineRunsClient) Cancel(ctx context.Context, resourceGroupName string, factoryName string, runID string, isRecursive *bool) (result autorest.Response, err error) { if err := validation.Validate([]validation.Validation{ {TargetValue: resourceGroupName, Constraints: []validation.Constraint{{Target: "resourceGroupName", Name: validation.MaxLength, Rule: 90, Chain: nil}, @@ -59,7 +60,7 @@ func (client PipelineRunsClient) Cancel(ctx context.Context, resourceGroupName s return result, validation.NewError("datafactory.PipelineRunsClient", "Cancel", err.Error()) } - req, err := client.CancelPreparer(ctx, resourceGroupName, factoryName, runID) + req, err := client.CancelPreparer(ctx, resourceGroupName, factoryName, runID, isRecursive) if err != nil { err = autorest.NewErrorWithError(err, "datafactory.PipelineRunsClient", "Cancel", nil, "Failure preparing request") return @@ -81,7 +82,7 @@ func (client PipelineRunsClient) Cancel(ctx context.Context, resourceGroupName s } // CancelPreparer prepares the Cancel request. -func (client PipelineRunsClient) CancelPreparer(ctx context.Context, resourceGroupName string, factoryName string, runID string) (*http.Request, error) { +func (client PipelineRunsClient) CancelPreparer(ctx context.Context, resourceGroupName string, factoryName string, runID string, isRecursive *bool) (*http.Request, error) { pathParameters := map[string]interface{}{ "factoryName": autorest.Encode("path", factoryName), "resourceGroupName": autorest.Encode("path", resourceGroupName), @@ -93,6 +94,9 @@ func (client PipelineRunsClient) CancelPreparer(ctx context.Context, resourceGro queryParameters := map[string]interface{}{ "api-version": APIVersion, } + if isRecursive != nil { + queryParameters["isRecursive"] = autorest.Encode("query", *isRecursive) + } preparer := autorest.CreatePreparer( autorest.AsPost(),