Class CfnApplicationPropsMixin.InputProperty

When you configure the application input for a SQL-based Kinesis Data Analytics application, you specify the streaming source, the in-application stream name that is created, and the mapping between the two.

Inheritance

object

CfnApplicationPropsMixin.InputProperty

Implements

CfnApplicationPropsMixin.IInputProperty

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Amazon.CDK.CfnPropertyMixins.AWS.KinesisAnalyticsV2

Assembly: Amazon.CDK.CfnPropertyMixins.dll

Syntax (csharp)

public class CfnApplicationPropsMixin.InputProperty : CfnApplicationPropsMixin.IInputProperty

Syntax (vb)

Public Class CfnApplicationPropsMixin.InputProperty Implements CfnApplicationPropsMixin.IInputProperty

Remarks

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

ExampleMetadata: fixture=_generated

Examples

// The code below shows an example of how to instantiate this type.
             // The values are placeholders you should change.
             using Amazon.CDK.CfnPropertyMixins.AWS.KinesisAnalyticsV2;

             var inputProperty = new InputProperty {
                 InputParallelism = new InputParallelismProperty {
                     Count = 123
                 },
                 InputProcessingConfiguration = new InputProcessingConfigurationProperty {
                     InputLambdaProcessor = new InputLambdaProcessorProperty {
                         ResourceArn = "resourceArn"
                     }
                 },
                 InputSchema = new InputSchemaProperty {
                     RecordColumns = new [] { new RecordColumnProperty {
                         Mapping = "mapping",
                         Name = "name",
                         SqlType = "sqlType"
                     } },
                     RecordEncoding = "recordEncoding",
                     RecordFormat = new RecordFormatProperty {
                         MappingParameters = new MappingParametersProperty {
                             CsvMappingParameters = new CSVMappingParametersProperty {
                                 RecordColumnDelimiter = "recordColumnDelimiter",
                                 RecordRowDelimiter = "recordRowDelimiter"
                             },
                             JsonMappingParameters = new JSONMappingParametersProperty {
                                 RecordRowPath = "recordRowPath"
                             }
                         },
                         RecordFormatType = "recordFormatType"
                     }
                 },
                 KinesisFirehoseInput = new KinesisFirehoseInputProperty {
                     ResourceArn = "resourceArn"
                 },
                 KinesisStreamsInput = new KinesisStreamsInputProperty {
                     ResourceArn = "resourceArn"
                 },
                 NamePrefix = "namePrefix"
             };

Synopsis

Constructors

InputProperty()

When you configure the application input for a SQL-based Kinesis Data Analytics application, you specify the streaming source, the in-application stream name that is created, and the mapping between the two.

Properties

InputParallelism	Describes the number of in-application streams to create.
InputProcessingConfiguration	The InputProcessingConfiguration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is InputLambdaProcessor .
InputSchema	Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
KinesisFirehoseInput	If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
KinesisStreamsInput	If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
NamePrefix	The name prefix to use when creating an in-application stream.

Constructors

InputProperty()

When you configure the application input for a SQL-based Kinesis Data Analytics application, you specify the streaming source, the in-application stream name that is created, and the mapping between the two.

public InputProperty()

Remarks

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

ExampleMetadata: fixture=_generated

Examples

// The code below shows an example of how to instantiate this type.
             // The values are placeholders you should change.
             using Amazon.CDK.CfnPropertyMixins.AWS.KinesisAnalyticsV2;

             var inputProperty = new InputProperty {
                 InputParallelism = new InputParallelismProperty {
                     Count = 123
                 },
                 InputProcessingConfiguration = new InputProcessingConfigurationProperty {
                     InputLambdaProcessor = new InputLambdaProcessorProperty {
                         ResourceArn = "resourceArn"
                     }
                 },
                 InputSchema = new InputSchemaProperty {
                     RecordColumns = new [] { new RecordColumnProperty {
                         Mapping = "mapping",
                         Name = "name",
                         SqlType = "sqlType"
                     } },
                     RecordEncoding = "recordEncoding",
                     RecordFormat = new RecordFormatProperty {
                         MappingParameters = new MappingParametersProperty {
                             CsvMappingParameters = new CSVMappingParametersProperty {
                                 RecordColumnDelimiter = "recordColumnDelimiter",
                                 RecordRowDelimiter = "recordRowDelimiter"
                             },
                             JsonMappingParameters = new JSONMappingParametersProperty {
                                 RecordRowPath = "recordRowPath"
                             }
                         },
                         RecordFormatType = "recordFormatType"
                     }
                 },
                 KinesisFirehoseInput = new KinesisFirehoseInputProperty {
                     ResourceArn = "resourceArn"
                 },
                 KinesisStreamsInput = new KinesisStreamsInputProperty {
                     ResourceArn = "resourceArn"
                 },
                 NamePrefix = "namePrefix"
             };

Properties

InputParallelism

Describes the number of in-application streams to create.

public object? InputParallelism { get; set; }

Property Value

object

Remarks

See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-input.html#cfn-kinesisanalyticsv2-application-input-inputparallelism

Type union: either IResolvable or CfnApplicationPropsMixin.IInputParallelismProperty

InputProcessingConfiguration

The InputProcessingConfiguration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is InputLambdaProcessor .

public object? InputProcessingConfiguration { get; set; }

Property Value

object

Remarks

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

Type union: either IResolvable or CfnApplicationPropsMixin.IInputProcessingConfigurationProperty

InputSchema

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.

public object? InputSchema { get; set; }

Property Value

object

Remarks

Also used to describe the format of the reference data source.

See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-input.html#cfn-kinesisanalyticsv2-application-input-inputschema

Type union: either IResolvable or CfnApplicationPropsMixin.IInputSchemaProperty

KinesisFirehoseInput

If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.

public object? KinesisFirehoseInput { get; set; }

Property Value

object

Remarks

See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-input.html#cfn-kinesisanalyticsv2-application-input-kinesisfirehoseinput

Type union: either IResolvable or CfnApplicationPropsMixin.IKinesisFirehoseInputProperty

KinesisStreamsInput

If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).

public object? KinesisStreamsInput { get; set; }

Property Value

object

Remarks

See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-input.html#cfn-kinesisanalyticsv2-application-input-kinesisstreamsinput

Type union: either IResolvable or CfnApplicationPropsMixin.IKinesisStreamsInputProperty

NamePrefix

The name prefix to use when creating an in-application stream.

public string? NamePrefix { get; set; }

Property Value

string

Remarks

Suppose that you specify a prefix " MyInApplicationStream ." Kinesis Data Analytics then creates one or more (as per the InputParallelism count you specified) in-application streams with the names " MyInApplicationStream_001 ," " MyInApplicationStream_002 ," and so on.

See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-input.html#cfn-kinesisanalyticsv2-application-input-nameprefix

Implements

CfnApplicationPropsMixin.IInputProperty