diff --git a/profiles/preview/datafactory/mgmt/datafactory/models.go b/profiles/preview/datafactory/mgmt/datafactory/models.go index 516889aa5717..62144fdda5c9 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 @@ -1303,6 +1315,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 @@ -1361,6 +1375,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 @@ -1654,6 +1669,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/models.go b/services/datafactory/mgmt/2018-06-01/datafactory/models.go index e80a85460862..4662c4d78980 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 @@ -6012,6 +6053,301 @@ func (aslstp *AmazonS3LinkedServiceTypeProperties) UnmarshalJSON(body []byte) er return nil } +// AppendVariableActivity append value for a Variable of type Array. +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 { + // VariableName - Name of the variable whose value needs to be appended to. + VariableName *string `json:"variableName,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 @@ -11262,7 +11598,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"` } @@ -11400,6 +11736,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 @@ -12183,7 +12529,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"` } @@ -12321,6 +12667,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 @@ -24239,6 +24595,8 @@ func (cs *ConcurSource) UnmarshalJSON(body []byte) error { // 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) @@ -24260,7 +24618,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"` } @@ -24272,6 +24630,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) @@ -24446,6 +24812,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 @@ -24590,7 +24966,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"` } @@ -24734,6 +25110,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 @@ -27867,7 +28253,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"` } @@ -28005,6 +28391,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 @@ -29132,7 +29528,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"` } @@ -29270,6 +29666,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 @@ -29460,7 +29866,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"` } @@ -29598,6 +30004,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 @@ -29775,7 +30191,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"` } @@ -29913,6 +30329,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 @@ -30090,7 +30516,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"` } @@ -30228,6 +30654,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 @@ -37996,7 +38432,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"` } @@ -38128,6 +38564,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 @@ -38302,7 +38748,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"` } @@ -38440,6 +38886,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 @@ -38688,7 +39144,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"` } @@ -38928,6 +39384,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 @@ -41336,7 +41802,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"` } @@ -41468,6 +41934,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 @@ -41621,7 +42097,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"` } @@ -41753,6 +42229,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 @@ -42567,7 +43053,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"` } @@ -42705,6 +43191,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 @@ -47921,7 +48417,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"` } @@ -48059,6 +48555,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 @@ -48845,7 +49351,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"` } @@ -48983,6 +49489,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 @@ -50050,7 +50566,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"` } @@ -50188,6 +50704,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 @@ -50393,7 +50919,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"` } @@ -50531,6 +51057,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 @@ -50742,7 +51278,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"` } @@ -50880,6 +51416,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 @@ -55410,7 +55956,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"` } @@ -55542,6 +56088,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 @@ -61257,7 +61813,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"` } @@ -61395,6 +61951,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 @@ -75848,6 +76414,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. @@ -75868,6 +76436,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 } @@ -75915,6 +76486,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 @@ -91596,6 +92176,301 @@ func (sns *ServiceNowSource) UnmarshalJSON(body []byte) error { return nil } +// 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 { + // VariableName - Name of the variable whose value needs to be set. + VariableName *string `json:"variableName,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. @@ -96191,7 +97066,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"` } @@ -96329,6 +97204,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 @@ -101546,7 +102431,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"` } @@ -101678,6 +102563,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 @@ -101882,6 +102777,14 @@ type UserProperty struct { Value interface{} `json:"value,omitempty"` } +// VariableSpecification definition of a single variable for a 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. @@ -103168,7 +104071,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"` } @@ -103300,6 +104203,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 @@ -103455,7 +104368,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"` } @@ -103593,6 +104506,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