Class: AWSCDK::AppFlow::CfnFlow::TaskProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
app_flow/cfn_flow.rb

Overview

A class for modeling different type of tasks.

Task implementation varies based on the TaskType .

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(source_fields:, task_type:, connector_operator: nil, destination_field: nil, task_properties: nil) ⇒ TaskProperty

Returns a new instance of TaskProperty.

Parameters:



3146
3147
3148
3149
3150
3151
3152
3153
3154
3155
3156
3157
 
# File 'app_flow/cfn_flow.rb', line 3146

def initialize(source_fields:, task_type:, connector_operator: nil, destination_field: nil, task_properties: nil)
  @source_fields = source_fields
  Jsii::Type.check_type(@source_fields, JSON.parse(Base64.strict_decode64("eyJjb2xsZWN0aW9uIjp7ImVsZW1lbnR0eXBlIjp7InByaW1pdGl2ZSI6InN0cmluZyJ9LCJraW5kIjoiYXJyYXkifX0=")), "sourceFields")
  @task_type = task_type
  Jsii::Type.check_type(@task_type, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "taskType")
  @connector_operator = connector_operator.is_a?(Hash) ? ::AWSCDK::AppFlow::CfnFlow::ConnectorOperatorProperty.new(**connector_operator.transform_keys(&:to_sym)) : connector_operator
  Jsii::Type.check_type(@connector_operator, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19hcHBmbG93LkNmbkZsb3cuQ29ubmVjdG9yT3BlcmF0b3JQcm9wZXJ0eSJ9XX19")), "connectorOperator") unless @connector_operator.nil?
  @destination_field = destination_field
  Jsii::Type.check_type(@destination_field, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "destinationField") unless @destination_field.nil?
  @task_properties = task_properties
  Jsii::Type.check_type(@task_properties, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImNvbGxlY3Rpb24iOnsiZWxlbWVudHR5cGUiOnsidW5pb24iOnsidHlwZXMiOlt7ImZxbiI6ImF3cy1jZGstbGliLklSZXNvbHZhYmxlIn0seyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfYXBwZmxvdy5DZm5GbG93LlRhc2tQcm9wZXJ0aWVzT2JqZWN0UHJvcGVydHkifV19fSwia2luZCI6ImFycmF5In19XX19")), "taskProperties") unless @task_properties.nil?
end

Instance Attribute Details

#connector_operator ⇒ AWSCDK::IResolvable, ... (readonly)

The operation to be performed on the provided source fields.

Returns:

See Also:



3175
3176
3177
 
# File 'app_flow/cfn_flow.rb', line 3175

def connector_operator
  @connector_operator
end

#destination_field ⇒ String? (readonly)

A field in a destination connector, or a field value against which Amazon AppFlow validates a source field.

Returns:

  • (String, nil)

See Also:



3180
3181
3182
 
# File 'app_flow/cfn_flow.rb', line 3180

def destination_field
  @destination_field
end

#source_fields ⇒ Array<String> (readonly)

The source fields to which a particular task is applied.

Returns:

  • (Array<String>)

See Also:



3163
3164
3165
 
# File 'app_flow/cfn_flow.rb', line 3163

def source_fields
  @source_fields
end

#task_properties ⇒ AWSCDK::IResolvable, ... (readonly)

A map used to store task-related information.

The execution service looks for particular information based on the TaskType .

Returns:

See Also:



3187
3188
3189
 
# File 'app_flow/cfn_flow.rb', line 3187

def task_properties
  @task_properties
end

#task_type ⇒ String (readonly)

Specifies the particular task implementation that Amazon AppFlow performs.

Allowed values : Arithmetic | Filter | Map | Map_all | Mask | Merge | Truncate | Validate

Returns:

  • (String)

See Also:



3170
3171
3172
 
# File 'app_flow/cfn_flow.rb', line 3170

def task_type
  @task_type
end

Class Method Details

.jsii_properties ⇒ Object 



3189
3190
3191
3192
3193
3194
3195
3196
3197
 
# File 'app_flow/cfn_flow.rb', line 3189

def self.jsii_properties
  {
    :source_fields => "sourceFields",
    :task_type => "taskType",
    :connector_operator => "connectorOperator",
    :destination_field => "destinationField",
    :task_properties => "taskProperties",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



3199
3200
3201
3202
3203
3204
3205
3206
3207
3208
3209
 
# File 'app_flow/cfn_flow.rb', line 3199

def to_jsii
  result = {}
  result.merge!({
    "sourceFields" => @source_fields,
    "taskType" => @task_type,
    "connectorOperator" => @connector_operator,
    "destinationField" => @destination_field,
    "taskProperties" => @task_properties,
  })
  result.compact
end