Class: AWSCDK::KinesisAnalytics::CfnApplicationOutputV2::OutputProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
kinesis_analytics/cfn_application_output_v2.rb

Overview

Describes a SQL-based Kinesis Data Analytics application's output configuration, in which you identify an in-application stream and a destination where you want the in-application stream data to be written.

The destination can be a Kinesis data stream or a Kinesis Data Firehose delivery stream.

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(destination_schema:, kinesis_firehose_output: nil, kinesis_streams_output: nil, lambda_output: nil, name: nil) ⇒ OutputProperty

Returns a new instance of OutputProperty.

Parameters:



667
668
669
670
671
672
673
674
675
676
677
678
 
# File 'kinesis_analytics/cfn_application_output_v2.rb', line 667

def initialize(destination_schema:, kinesis_firehose_output: nil, kinesis_streams_output: nil, lambda_output: nil, name: nil)
  @destination_schema = destination_schema.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationOutputV2::DestinationSchemaProperty.new(**destination_schema.transform_keys(&:to_sym)) : destination_schema
  Jsii::Type.check_type(@destination_schema, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uT3V0cHV0VjIuRGVzdGluYXRpb25TY2hlbWFQcm9wZXJ0eSJ9XX19")), "destinationSchema")
  @kinesis_firehose_output = kinesis_firehose_output.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationOutputV2::KinesisFirehoseOutputProperty.new(**kinesis_firehose_output.transform_keys(&:to_sym)) : kinesis_firehose_output
  Jsii::Type.check_type(@kinesis_firehose_output, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uT3V0cHV0VjIuS2luZXNpc0ZpcmVob3NlT3V0cHV0UHJvcGVydHkifV19fQ==")), "kinesisFirehoseOutput") unless @kinesis_firehose_output.nil?
  @kinesis_streams_output = kinesis_streams_output.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationOutputV2::KinesisStreamsOutputProperty.new(**kinesis_streams_output.transform_keys(&:to_sym)) : kinesis_streams_output
  Jsii::Type.check_type(@kinesis_streams_output, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uT3V0cHV0VjIuS2luZXNpc1N0cmVhbXNPdXRwdXRQcm9wZXJ0eSJ9XX19")), "kinesisStreamsOutput") unless @kinesis_streams_output.nil?
  @lambda_output = lambda_output.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationOutputV2::LambdaOutputProperty.new(**lambda_output.transform_keys(&:to_sym)) : lambda_output
  Jsii::Type.check_type(@lambda_output, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uT3V0cHV0VjIuTGFtYmRhT3V0cHV0UHJvcGVydHkifV19fQ==")), "lambdaOutput") unless @lambda_output.nil?
  @name = name
  Jsii::Type.check_type(@name, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "name") unless @name.nil?
end

Instance Attribute Details

#destination_schema ⇒ AWSCDK::IResolvable, AWSCDK::KinesisAnalytics::CfnApplicationOutputV2::DestinationSchemaProperty (readonly)

Describes the data format when records are written to the destination.

Returns:

See Also:



684
685
686
 
# File 'kinesis_analytics/cfn_application_output_v2.rb', line 684

def destination_schema
  @destination_schema
end

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

Identifies a Kinesis Data Firehose delivery stream as the destination.

Returns:

See Also:



689
690
691
 
# File 'kinesis_analytics/cfn_application_output_v2.rb', line 689

def kinesis_firehose_output
  @kinesis_firehose_output
end

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

Identifies a Kinesis data stream as the destination.

Returns:

See Also:



694
695
696
 
# File 'kinesis_analytics/cfn_application_output_v2.rb', line 694

def kinesis_streams_output
  @kinesis_streams_output
end

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

Identifies an Amazon Lambda function as the destination.

Returns:

See Also:



699
700
701
 
# File 'kinesis_analytics/cfn_application_output_v2.rb', line 699

def lambda_output
  @lambda_output
end

#name ⇒ String? (readonly)

The name of the in-application stream.

Returns:

  • (String, nil)

See Also:



704
705
706
 
# File 'kinesis_analytics/cfn_application_output_v2.rb', line 704

def name
  @name
end

Class Method Details

.jsii_properties ⇒ Object 



706
707
708
709
710
711
712
713
714
 
# File 'kinesis_analytics/cfn_application_output_v2.rb', line 706

def self.jsii_properties
  {
    :destination_schema => "destinationSchema",
    :kinesis_firehose_output => "kinesisFirehoseOutput",
    :kinesis_streams_output => "kinesisStreamsOutput",
    :lambda_output => "lambdaOutput",
    :name => "name",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



716
717
718
719
720
721
722
723
724
725
726
 
# File 'kinesis_analytics/cfn_application_output_v2.rb', line 716

def to_jsii
  result = {}
  result.merge!({
    "destinationSchema" => @destination_schema,
    "kinesisFirehoseOutput" => @kinesis_firehose_output,
    "kinesisStreamsOutput" => @kinesis_streams_output,
    "lambdaOutput" => @lambda_output,
    "name" => @name,
  })
  result.compact
end