Class: AWSCDK::KinesisAnalyticsv2::CfnApplicationOutput::OutputProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
kinesis_analyticsv2/cfn_application_output.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:



666
667
668
669
670
671
672
673
674
675
676
677
 
# File 'kinesis_analyticsv2/cfn_application_output.rb', line 666

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::KinesisAnalyticsv2::CfnApplicationOutput::DestinationSchemaProperty.new(**destination_schema.transform_keys(&:to_sym)) : destination_schema
  Jsii::Type.check_type(@destination_schema, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzdjIuQ2ZuQXBwbGljYXRpb25PdXRwdXQuRGVzdGluYXRpb25TY2hlbWFQcm9wZXJ0eSJ9XX19")), "destinationSchema")
  @kinesis_firehose_output = kinesis_firehose_output.is_a?(Hash) ? ::AWSCDK::KinesisAnalyticsv2::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("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzdjIuQ2ZuQXBwbGljYXRpb25PdXRwdXQuS2luZXNpc0ZpcmVob3NlT3V0cHV0UHJvcGVydHkifV19fQ==")), "kinesisFirehoseOutput") unless @kinesis_firehose_output.nil?
  @kinesis_streams_output = kinesis_streams_output.is_a?(Hash) ? ::AWSCDK::KinesisAnalyticsv2::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("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzdjIuQ2ZuQXBwbGljYXRpb25PdXRwdXQuS2luZXNpc1N0cmVhbXNPdXRwdXRQcm9wZXJ0eSJ9XX19")), "kinesisStreamsOutput") unless @kinesis_streams_output.nil?
  @lambda_output = lambda_output.is_a?(Hash) ? ::AWSCDK::KinesisAnalyticsv2::CfnApplicationOutput::LambdaOutputProperty.new(**lambda_output.transform_keys(&:to_sym)) : lambda_output
  Jsii::Type.check_type(@lambda_output, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzdjIuQ2ZuQXBwbGljYXRpb25PdXRwdXQuTGFtYmRhT3V0cHV0UHJvcGVydHkifV19fQ==")), "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::KinesisAnalyticsv2::CfnApplicationOutput::DestinationSchemaProperty (readonly)

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

Returns:

See Also:



683
684
685
 
# File 'kinesis_analyticsv2/cfn_application_output.rb', line 683

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:



688
689
690
 
# File 'kinesis_analyticsv2/cfn_application_output.rb', line 688

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:



693
694
695
 
# File 'kinesis_analyticsv2/cfn_application_output.rb', line 693

def kinesis_streams_output
  @kinesis_streams_output
end

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

Identifies an Amazon Lambda function as the destination.

Returns:

See Also:



698
699
700
 
# File 'kinesis_analyticsv2/cfn_application_output.rb', line 698

def lambda_output
  @lambda_output
end

#name ⇒ String? (readonly)

The name of the in-application stream.

Returns:

  • (String, nil)

See Also:



703
704
705
 
# File 'kinesis_analyticsv2/cfn_application_output.rb', line 703

def name
  @name
end

Class Method Details

.jsii_properties ⇒ Object 



705
706
707
708
709
710
711
712
713
 
# File 'kinesis_analyticsv2/cfn_application_output.rb', line 705

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 



715
716
717
718
719
720
721
722
723
724
725
 
# File 'kinesis_analyticsv2/cfn_application_output.rb', line 715

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