Class: AWSCDK::KinesisAnalytics::CfnApplicationOutput::OutputProperty

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

Overview

Describes application 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 an Amazon Kinesis stream or an Amazon Kinesis Firehose delivery stream.

For limits on how many destinations an application can write and other limitations, see Limits .

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:



708
709
710
711
712
713
714
715
716
717
718
719
 
# File 'kinesis_analytics/cfn_application_output.rb', line 708

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::CfnApplicationOutput::DestinationSchemaProperty.new(**destination_schema.transform_keys(&:to_sym)) : destination_schema
  Jsii::Type.check_type(@destination_schema, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uT3V0cHV0LkRlc3RpbmF0aW9uU2NoZW1hUHJvcGVydHkifV19fQ==")), "destinationSchema")
  @kinesis_firehose_output = kinesis_firehose_output.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationOutput::KinesisFirehoseOutputProperty.new(**kinesis_firehose_output.transform_keys(&:to_sym)) : kinesis_firehose_output
  Jsii::Type.check_type(@kinesis_firehose_output, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uT3V0cHV0LktpbmVzaXNGaXJlaG9zZU91dHB1dFByb3BlcnR5In1dfX0=")), "kinesisFirehoseOutput") unless @kinesis_firehose_output.nil?
  @kinesis_streams_output = kinesis_streams_output.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationOutput::KinesisStreamsOutputProperty.new(**kinesis_streams_output.transform_keys(&:to_sym)) : kinesis_streams_output
  Jsii::Type.check_type(@kinesis_streams_output, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uT3V0cHV0LktpbmVzaXNTdHJlYW1zT3V0cHV0UHJvcGVydHkifV19fQ==")), "kinesisStreamsOutput") unless @kinesis_streams_output.nil?
  @lambda_output = lambda_output.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationOutput::LambdaOutputProperty.new(**lambda_output.transform_keys(&:to_sym)) : lambda_output
  Jsii::Type.check_type(@lambda_output, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uT3V0cHV0LkxhbWJkYU91dHB1dFByb3BlcnR5In1dfX0=")), "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::CfnApplicationOutput::DestinationSchemaProperty (readonly)

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

For more information, see Configuring Application Output .

Returns:

See Also:



727
728
729
 
# File 'kinesis_analytics/cfn_application_output.rb', line 727

def destination_schema
  @destination_schema
end

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

Identifies an Amazon Kinesis Firehose delivery stream as the destination.

Returns:

See Also:



732
733
734
 
# File 'kinesis_analytics/cfn_application_output.rb', line 732

def kinesis_firehose_output
  @kinesis_firehose_output
end

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

Identifies an Amazon Kinesis stream as the destination.

Returns:

See Also:



737
738
739
 
# File 'kinesis_analytics/cfn_application_output.rb', line 737

def kinesis_streams_output
  @kinesis_streams_output
end

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

Identifies an AWS Lambda function as the destination.

Returns:

See Also:



742
743
744
 
# File 'kinesis_analytics/cfn_application_output.rb', line 742

def lambda_output
  @lambda_output
end

#name ⇒ String? (readonly)

Name of the in-application stream.

Returns:

  • (String, nil)

See Also:



747
748
749
 
# File 'kinesis_analytics/cfn_application_output.rb', line 747

def name
  @name
end

Class Method Details

.jsii_properties ⇒ Object 



749
750
751
752
753
754
755
756
757
 
# File 'kinesis_analytics/cfn_application_output.rb', line 749

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 



759
760
761
762
763
764
765
766
767
768
769
 
# File 'kinesis_analytics/cfn_application_output.rb', line 759

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