Class: AWSCDK::KinesisAnalytics::CfnApplicationV2::InputProcessingConfigurationProperty

Inherits:

Jsii::Struct

• Object
• Jsii::Struct
• AWSCDK::KinesisAnalytics::CfnApplicationV2::InputProcessingConfigurationProperty

Defined in:

kinesis_analytics/cfn_application_v2.rb

Overview

For an SQL-based Amazon Kinesis Data Analytics application, describes a processor that is used to preprocess the records in the stream before being processed by your application code.

Currently, the only input processor available is Amazon Lambda .

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-inputprocessingconfiguration.html

Instance Attribute Summary

• #input_lambda_processor ⇒ AWSCDK::IResolvable, ... readonly

  The InputLambdaProcessor that is used to preprocess the records in the stream before being processed by your application code.

Class Method Summary

• .jsii_properties ⇒ Object

Instance Method Summary

• #initialize(input_lambda_processor: nil) ⇒ InputProcessingConfigurationProperty constructor

  A new instance of InputProcessingConfigurationProperty.

• #to_jsii ⇒ Object

Constructor Details

#initialize(input_lambda_processor: nil) ⇒ InputProcessingConfigurationProperty

Returns a new instance of InputProcessingConfigurationProperty.

Parameters:

• input_lambda_processor (AWSCDK::IResolvable, AWSCDK::KinesisAnalytics::CfnApplicationV2::InputLambdaProcessorProperty, nil) (defaults to: nil) —

  The InputLambdaProcessor that is used to preprocess the records in the stream before being processed by your application code.

# File 'kinesis_analytics/cfn_application_v2.rb', line 1517

def initialize(input_lambda_processor: nil)
  @input_lambda_processor = input_lambda_processor.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationV2::InputLambdaProcessorProperty.new(**input_lambda_processor.transform_keys(&:to_sym)) : input_lambda_processor
  Jsii::Type.check_type(@input_lambda_processor, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uVjIuSW5wdXRMYW1iZGFQcm9jZXNzb3JQcm9wZXJ0eSJ9XX19")), "inputLambdaProcessor") unless @input_lambda_processor.nil?
end

Instance Attribute Details

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

The InputLambdaProcessor that is used to preprocess the records in the stream before being processed by your application code.

Returns:

• (AWSCDK::IResolvable, AWSCDK::KinesisAnalytics::CfnApplicationV2::InputLambdaProcessorProperty, nil)

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-inputprocessingconfiguration.html#cfn-kinesisanalyticsv2-application-inputprocessingconfiguration-inputlambdaprocessor

# File 'kinesis_analytics/cfn_application_v2.rb', line 1526

def input_lambda_processor
  @input_lambda_processor
end

Class Method Details

.jsii_properties ⇒ Object

# File 'kinesis_analytics/cfn_application_v2.rb', line 1528

def self.jsii_properties
  {
    :input_lambda_processor => "inputLambdaProcessor",
  }
end

Instance Method Details

#to_jsii ⇒ Object

# File 'kinesis_analytics/cfn_application_v2.rb', line 1534

def to_jsii
  result = {}
  result.merge!({
    "inputLambdaProcessor" => @input_lambda_processor,
  })
  result.compact
end