Class: AWSCDK::StepFunctionsTasks::TransformInput

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
step_functions_tasks/transform_input.rb

Overview

Dataset to be transformed and the Amazon S3 location where it is stored.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(transform_data_source:, compression_type: nil, content_type: nil, split_type: nil) ⇒ TransformInput

Returns a new instance of TransformInput.

Parameters:



11
12
13
14
15
16
17
18
19
20
 
# File 'step_functions_tasks/transform_input.rb', line 11

def initialize(transform_data_source:, compression_type: nil, content_type: nil, split_type: nil)
  @transform_data_source = transform_data_source.is_a?(Hash) ? ::AWSCDK::StepFunctionsTasks::TransformDataSource.new(**transform_data_source.transform_keys(&:to_sym)) : transform_data_source
  Jsii::Type.check_type(@transform_data_source, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9uc190YXNrcy5UcmFuc2Zvcm1EYXRhU291cmNlIn0=")), "transformDataSource")
  @compression_type = compression_type
  Jsii::Type.check_type(@compression_type, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9uc190YXNrcy5Db21wcmVzc2lvblR5cGUifQ==")), "compressionType") unless @compression_type.nil?
  @content_type = content_type
  Jsii::Type.check_type(@content_type, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "contentType") unless @content_type.nil?
  @split_type = split_type
  Jsii::Type.check_type(@split_type, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9uc190YXNrcy5TcGxpdFR5cGUifQ==")), "splitType") unless @split_type.nil?
end

Instance Attribute Details

#compression_type ⇒ AWSCDK::StepFunctionsTasks::CompressionType? (readonly)

Note:

Default: NONE

The compression type of the transform data.

Returns:



30
31
32
 
# File 'step_functions_tasks/transform_input.rb', line 30

def compression_type
  @compression_type
end

#content_type ⇒ String? (readonly)

Note:

Default: - None

Multipurpose internet mail extension (MIME) type of the data.

Returns:

  • (String, nil) 


35
36
37
 
# File 'step_functions_tasks/transform_input.rb', line 35

def content_type
  @content_type
end

#split_type ⇒ AWSCDK::StepFunctionsTasks::SplitType? (readonly)

Note:

Default: NONE

Method to use to split the transform job's data files into smaller batches.

Returns:



40
41
42
 
# File 'step_functions_tasks/transform_input.rb', line 40

def split_type
  @split_type
end

#transform_data_source ⇒ AWSCDK::StepFunctionsTasks::TransformDataSource (readonly)

S3 location of the channel data.

Returns:



25
26
27
 
# File 'step_functions_tasks/transform_input.rb', line 25

def transform_data_source
  @transform_data_source
end

Class Method Details

.jsii_properties ⇒ Object 



42
43
44
45
46
47
48
49
 
# File 'step_functions_tasks/transform_input.rb', line 42

def self.jsii_properties
  {
    :transform_data_source => "transformDataSource",
    :compression_type => "compressionType",
    :content_type => "contentType",
    :split_type => "splitType",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



51
52
53
54
55
56
57
58
59
60
 
# File 'step_functions_tasks/transform_input.rb', line 51

def to_jsii
  result = {}
  result.merge!({
    "transformDataSource" => @transform_data_source,
    "compressionType" => @compression_type,
    "contentType" => @content_type,
    "splitType" => @split_type,
  })
  result.compact
end