awskinesisanalytics

package
v2.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 9, 2022 License: Apache-2.0 Imports: 6 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CfnApplicationCloudWatchLoggingOptionV2_CFN_RESOURCE_TYPE_NAME 

func CfnApplicationCloudWatchLoggingOptionV2_CFN_RESOURCE_TYPE_NAME() *string

func CfnApplicationCloudWatchLoggingOptionV2_IsCfnElement 

func CfnApplicationCloudWatchLoggingOptionV2_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element.

func CfnApplicationCloudWatchLoggingOptionV2_IsCfnResource 

func CfnApplicationCloudWatchLoggingOptionV2_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource.

func CfnApplicationCloudWatchLoggingOptionV2_IsConstruct 

func CfnApplicationCloudWatchLoggingOptionV2_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func CfnApplicationOutputV2_CFN_RESOURCE_TYPE_NAME 

func CfnApplicationOutputV2_CFN_RESOURCE_TYPE_NAME() *string

func CfnApplicationOutputV2_IsCfnElement 

func CfnApplicationOutputV2_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element.

func CfnApplicationOutputV2_IsCfnResource 

func CfnApplicationOutputV2_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource.

func CfnApplicationOutputV2_IsConstruct 

func CfnApplicationOutputV2_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func CfnApplicationOutput_CFN_RESOURCE_TYPE_NAME 

func CfnApplicationOutput_CFN_RESOURCE_TYPE_NAME() *string

func CfnApplicationOutput_IsCfnElement 

func CfnApplicationOutput_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element.

func CfnApplicationOutput_IsCfnResource 

func CfnApplicationOutput_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource.

func CfnApplicationOutput_IsConstruct 

func CfnApplicationOutput_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func CfnApplicationReferenceDataSourceV2_CFN_RESOURCE_TYPE_NAME 

func CfnApplicationReferenceDataSourceV2_CFN_RESOURCE_TYPE_NAME() *string

func CfnApplicationReferenceDataSourceV2_IsCfnElement 

func CfnApplicationReferenceDataSourceV2_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element.

func CfnApplicationReferenceDataSourceV2_IsCfnResource 

func CfnApplicationReferenceDataSourceV2_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource.

func CfnApplicationReferenceDataSourceV2_IsConstruct 

func CfnApplicationReferenceDataSourceV2_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func CfnApplicationReferenceDataSource_CFN_RESOURCE_TYPE_NAME 

func CfnApplicationReferenceDataSource_CFN_RESOURCE_TYPE_NAME() *string

func CfnApplicationReferenceDataSource_IsCfnElement 

func CfnApplicationReferenceDataSource_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element.

func CfnApplicationReferenceDataSource_IsCfnResource 

func CfnApplicationReferenceDataSource_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource.

func CfnApplicationReferenceDataSource_IsConstruct 

func CfnApplicationReferenceDataSource_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func CfnApplicationV2_CFN_RESOURCE_TYPE_NAME 

func CfnApplicationV2_CFN_RESOURCE_TYPE_NAME() *string

func CfnApplicationV2_IsCfnElement 

func CfnApplicationV2_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element.

func CfnApplicationV2_IsCfnResource 

func CfnApplicationV2_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource.

func CfnApplicationV2_IsConstruct 

func CfnApplicationV2_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func CfnApplication_CFN_RESOURCE_TYPE_NAME 

func CfnApplication_CFN_RESOURCE_TYPE_NAME() *string

func CfnApplication_IsCfnElement 

func CfnApplication_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element.

func CfnApplication_IsCfnResource 

func CfnApplication_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource.

func CfnApplication_IsConstruct 

func CfnApplication_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func NewCfnApplicationCloudWatchLoggingOptionV2_Override 

func NewCfnApplicationCloudWatchLoggingOptionV2_Override(c CfnApplicationCloudWatchLoggingOptionV2, scope constructs.Construct, id *string, props *CfnApplicationCloudWatchLoggingOptionV2Props)

Create a new `AWS::KinesisAnalyticsV2::ApplicationCloudWatchLoggingOption`.

func NewCfnApplicationOutputV2_Override 

func NewCfnApplicationOutputV2_Override(c CfnApplicationOutputV2, scope constructs.Construct, id *string, props *CfnApplicationOutputV2Props)

Create a new `AWS::KinesisAnalyticsV2::ApplicationOutput`.

func NewCfnApplicationOutput_Override 

func NewCfnApplicationOutput_Override(c CfnApplicationOutput, scope constructs.Construct, id *string, props *CfnApplicationOutputProps)

Create a new `AWS::KinesisAnalytics::ApplicationOutput`.

func NewCfnApplicationReferenceDataSourceV2_Override 

func NewCfnApplicationReferenceDataSourceV2_Override(c CfnApplicationReferenceDataSourceV2, scope constructs.Construct, id *string, props *CfnApplicationReferenceDataSourceV2Props)

Create a new `AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource`.

func NewCfnApplicationReferenceDataSource_Override 

func NewCfnApplicationReferenceDataSource_Override(c CfnApplicationReferenceDataSource, scope constructs.Construct, id *string, props *CfnApplicationReferenceDataSourceProps)

Create a new `AWS::KinesisAnalytics::ApplicationReferenceDataSource`.

func NewCfnApplicationV2_Override 

func NewCfnApplicationV2_Override(c CfnApplicationV2, scope constructs.Construct, id *string, props *CfnApplicationV2Props)

Create a new `AWS::KinesisAnalyticsV2::Application`.

func NewCfnApplication_Override 

func NewCfnApplication_Override(c CfnApplication, scope constructs.Construct, id *string, props *CfnApplicationProps)

Create a new `AWS::KinesisAnalytics::Application`.

Types

type CfnApplication 

type CfnApplication interface {
	awscdk.CfnResource
	awscdk.IInspectable
	ApplicationCode() *string
	SetApplicationCode(val *string)
	ApplicationDescription() *string
	SetApplicationDescription(val *string)
	ApplicationName() *string
	SetApplicationName(val *string)
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	Inputs() interface{}
	SetInputs(val interface{})
	LogicalId() *string
	Node() constructs.Node
	Ref() *string
	Stack() awscdk.Stack
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	ToString() *string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::KinesisAnalytics::Application`.

The `AWS::KinesisAnalytics::Application` resource creates an Amazon Kinesis Data Analytics application. For more information, see the [Amazon Kinesis Data Analytics Developer Guide](https://docs.aws.amazon.com//kinesisanalytics/latest/dev/what-is.html) .

TODO: EXAMPLE

func NewCfnApplication 

func NewCfnApplication(scope constructs.Construct, id *string, props *CfnApplicationProps) CfnApplication

Create a new `AWS::KinesisAnalytics::Application`.

type CfnApplicationCloudWatchLoggingOptionV2 

type CfnApplicationCloudWatchLoggingOptionV2 interface {
	awscdk.CfnResource
	awscdk.IInspectable
	ApplicationName() *string
	SetApplicationName(val *string)
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CloudWatchLoggingOption() interface{}
	SetCloudWatchLoggingOption(val interface{})
	CreationStack() *[]*string
	LogicalId() *string
	Node() constructs.Node
	Ref() *string
	Stack() awscdk.Stack
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	ToString() *string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::KinesisAnalyticsV2::ApplicationCloudWatchLoggingOption`.

Adds an Amazon CloudWatch log stream to monitor application configuration errors.

TODO: EXAMPLE

func NewCfnApplicationCloudWatchLoggingOptionV2 

func NewCfnApplicationCloudWatchLoggingOptionV2(scope constructs.Construct, id *string, props *CfnApplicationCloudWatchLoggingOptionV2Props) CfnApplicationCloudWatchLoggingOptionV2

Create a new `AWS::KinesisAnalyticsV2::ApplicationCloudWatchLoggingOption`.

type CfnApplicationCloudWatchLoggingOptionV2Props 

type CfnApplicationCloudWatchLoggingOptionV2Props struct {
	// The name of the application.
	ApplicationName *string `json:"applicationName" yaml:"applicationName"`
	// Provides a description of Amazon CloudWatch logging options, including the log stream Amazon Resource Name (ARN).
	CloudWatchLoggingOption interface{} `json:"cloudWatchLoggingOption" yaml:"cloudWatchLoggingOption"`
}

Properties for defining a `CfnApplicationCloudWatchLoggingOptionV2`.

TODO: EXAMPLE

type CfnApplicationCloudWatchLoggingOptionV2_CloudWatchLoggingOptionProperty 

type CfnApplicationCloudWatchLoggingOptionV2_CloudWatchLoggingOptionProperty struct {
	// The ARN of the CloudWatch log to receive application messages.
	LogStreamArn *string `json:"logStreamArn" yaml:"logStreamArn"`
}

Provides a description of Amazon CloudWatch logging options, including the log stream Amazon Resource Name (ARN).

TODO: EXAMPLE

type CfnApplicationOutput 

type CfnApplicationOutput interface {
	awscdk.CfnResource
	awscdk.IInspectable
	ApplicationName() *string
	SetApplicationName(val *string)
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	LogicalId() *string
	Node() constructs.Node
	Output() interface{}
	SetOutput(val interface{})
	Ref() *string
	Stack() awscdk.Stack
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	ToString() *string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::KinesisAnalytics::ApplicationOutput`.

Adds an external destination to your Amazon Kinesis Analytics application.

If you want Amazon Kinesis Analytics to deliver data from an in-application stream within your application to an external destination (such as an Amazon Kinesis stream, an Amazon Kinesis Firehose delivery stream, or an Amazon Lambda function), you add the relevant configuration to your application using this operation. You can configure one or more outputs for your application. Each output configuration maps an in-application stream and an external destination.

You can use one of the output configurations to deliver data from your in-application error stream to an external destination so that you can analyze the errors. For more information, see [Understanding Application Output (Destination)](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-output.html) .

Any configuration update, including adding a streaming source using this operation, results in a new version of the application. You can use the `DescribeApplication` operation to find the current application version.

For the limits on the number of application inputs and outputs you can configure, see [Limits](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html) .

This operation requires permissions to perform the `kinesisanalytics:AddApplicationOutput` action.

TODO: EXAMPLE

func NewCfnApplicationOutput 

func NewCfnApplicationOutput(scope constructs.Construct, id *string, props *CfnApplicationOutputProps) CfnApplicationOutput

Create a new `AWS::KinesisAnalytics::ApplicationOutput`.

type CfnApplicationOutputProps 

type CfnApplicationOutputProps struct {
	// Name of the application to which you want to add the output configuration.
	ApplicationName *string `json:"applicationName" yaml:"applicationName"`
	// An array of objects, each describing one output configuration.
	//
	// In the output configuration, you specify the name of an in-application stream, a destination (that is, an Amazon Kinesis stream, an Amazon Kinesis Firehose delivery stream, or an AWS Lambda function), and record the formation to use when writing to the destination.
	Output interface{} `json:"output" yaml:"output"`
}

Properties for defining a `CfnApplicationOutput`.

TODO: EXAMPLE

type CfnApplicationOutputV2 

type CfnApplicationOutputV2 interface {
	awscdk.CfnResource
	awscdk.IInspectable
	ApplicationName() *string
	SetApplicationName(val *string)
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	LogicalId() *string
	Node() constructs.Node
	Output() interface{}
	SetOutput(val interface{})
	Ref() *string
	Stack() awscdk.Stack
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	ToString() *string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::KinesisAnalyticsV2::ApplicationOutput`.

Adds an external destination to your SQL-based Amazon Kinesis Data Analytics application.

If you want Kinesis Data Analytics to deliver data from an in-application stream within your application to an external destination (such as an Kinesis data stream, a Kinesis Data Firehose delivery stream, or an Amazon Lambda function), you add the relevant configuration to your application using this operation. You can configure one or more outputs for your application. Each output configuration maps an in-application stream and an external destination.

You can use one of the output configurations to deliver data from your in-application error stream to an external destination so that you can analyze the errors.

Any configuration update, including adding a streaming source using this operation, results in a new version of the application. You can use the [DescribeApplication](https://docs.aws.amazon.com/kinesisanalytics/latest/apiv2/API_DescribeApplication.html) operation to find the current application version.

TODO: EXAMPLE

func NewCfnApplicationOutputV2 

func NewCfnApplicationOutputV2(scope constructs.Construct, id *string, props *CfnApplicationOutputV2Props) CfnApplicationOutputV2

Create a new `AWS::KinesisAnalyticsV2::ApplicationOutput`.

type CfnApplicationOutputV2Props 

type CfnApplicationOutputV2Props struct {
	// The name of the application.
	ApplicationName *string `json:"applicationName" yaml:"applicationName"`
	// 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.
	Output interface{} `json:"output" yaml:"output"`
}

Properties for defining a `CfnApplicationOutputV2`.

TODO: EXAMPLE

type CfnApplicationOutputV2_DestinationSchemaProperty 

type CfnApplicationOutputV2_DestinationSchemaProperty struct {
	// Specifies the format of the records on the output stream.
	RecordFormatType *string `json:"recordFormatType" yaml:"recordFormatType"`
}

Describes the data format when records are written to the destination in a SQL-based Kinesis Data Analytics application.

TODO: EXAMPLE

type CfnApplicationOutputV2_KinesisFirehoseOutputProperty 

type CfnApplicationOutputV2_KinesisFirehoseOutputProperty struct {
	// The ARN of the destination delivery stream to write to.
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
}

For a SQL-based Kinesis Data Analytics application, when configuring application output, identifies a Kinesis Data Firehose delivery stream as the destination.

You provide the stream Amazon Resource Name (ARN) of the delivery stream.

TODO: EXAMPLE

type CfnApplicationOutputV2_KinesisStreamsOutputProperty 

type CfnApplicationOutputV2_KinesisStreamsOutputProperty struct {
	// The ARN of the destination Kinesis data stream to write to.
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
}

When you configure a SQL-based Kinesis Data Analytics application's output, identifies a Kinesis data stream as the destination.

You provide the stream Amazon Resource Name (ARN).

TODO: EXAMPLE

type CfnApplicationOutputV2_LambdaOutputProperty 

type CfnApplicationOutputV2_LambdaOutputProperty struct {
	// The Amazon Resource Name (ARN) of the destination Lambda function to write to.
	//
	// > To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see [Example ARNs: Amazon Lambda](https://docs.aws.amazon.com/general/latest/gr/aws-arns-and-namespaces.html#arn-syntax-lambda)
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
}

When you configure a SQL-based Kinesis Data Analytics application's output, identifies an Amazon Lambda function as the destination.

You provide the function Amazon Resource Name (ARN) of the Lambda function.

TODO: EXAMPLE

type CfnApplicationOutputV2_OutputProperty 

type CfnApplicationOutputV2_OutputProperty struct {
	// Describes the data format when records are written to the destination.
	DestinationSchema interface{} `json:"destinationSchema" yaml:"destinationSchema"`
	// Identifies a Kinesis Data Firehose delivery stream as the destination.
	KinesisFirehoseOutput interface{} `json:"kinesisFirehoseOutput" yaml:"kinesisFirehoseOutput"`
	// Identifies a Kinesis data stream as the destination.
	KinesisStreamsOutput interface{} `json:"kinesisStreamsOutput" yaml:"kinesisStreamsOutput"`
	// Identifies an Amazon Lambda function as the destination.
	LambdaOutput interface{} `json:"lambdaOutput" yaml:"lambdaOutput"`
	// The name of the in-application stream.
	Name *string `json:"name" yaml:"name"`
}

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.

TODO: EXAMPLE

type CfnApplicationOutput_DestinationSchemaProperty 

type CfnApplicationOutput_DestinationSchemaProperty struct {
	// Specifies the format of the records on the output stream.
	RecordFormatType *string `json:"recordFormatType" yaml:"recordFormatType"`
}

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

For more information, see [Configuring Application Output](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-output.html) .

TODO: EXAMPLE

type CfnApplicationOutput_KinesisFirehoseOutputProperty 

type CfnApplicationOutput_KinesisFirehoseOutputProperty struct {
	// ARN of the destination Amazon Kinesis Firehose delivery stream to write to.
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
	// ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination stream on your behalf.
	//
	// You need to grant the necessary permissions to this role.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
}

When configuring application output, identifies an Amazon Kinesis Firehose delivery stream as the destination.

You provide the stream Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to write to the stream on your behalf.

TODO: EXAMPLE

type CfnApplicationOutput_KinesisStreamsOutputProperty 

type CfnApplicationOutput_KinesisStreamsOutputProperty struct {
	// ARN of the destination Amazon Kinesis stream to write to.
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
	// ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination stream on your behalf.
	//
	// You need to grant the necessary permissions to this role.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
}

When configuring application output, identifies an Amazon Kinesis stream as the destination.

You provide the stream Amazon Resource Name (ARN) and also an IAM role ARN that Amazon Kinesis Analytics can use to write to the stream on your behalf.

TODO: EXAMPLE

type CfnApplicationOutput_LambdaOutputProperty 

type CfnApplicationOutput_LambdaOutputProperty struct {
	// Amazon Resource Name (ARN) of the destination Lambda function to write to.
	//
	// > To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see [Example ARNs: AWS Lambda](https://docs.aws.amazon.com//general/latest/gr/aws-arns-and-namespaces.html#arn-syntax-lambda)
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
	// ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function on your behalf.
	//
	// You need to grant the necessary permissions to this role.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
}

When configuring application output, identifies an AWS Lambda function as the destination.

You provide the function Amazon Resource Name (ARN) and also an IAM role ARN that Amazon Kinesis Analytics can use to write to the function on your behalf.

TODO: EXAMPLE

type CfnApplicationOutput_OutputProperty 

type CfnApplicationOutput_OutputProperty struct {
	// Describes the data format when records are written to the destination.
	//
	// For more information, see [Configuring Application Output](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-output.html) .
	DestinationSchema interface{} `json:"destinationSchema" yaml:"destinationSchema"`
	// Identifies an Amazon Kinesis Firehose delivery stream as the destination.
	KinesisFirehoseOutput interface{} `json:"kinesisFirehoseOutput" yaml:"kinesisFirehoseOutput"`
	// Identifies an Amazon Kinesis stream as the destination.
	KinesisStreamsOutput interface{} `json:"kinesisStreamsOutput" yaml:"kinesisStreamsOutput"`
	// Identifies an AWS Lambda function as the destination.
	LambdaOutput interface{} `json:"lambdaOutput" yaml:"lambdaOutput"`
	// Name of the in-application stream.
	Name *string `json:"name" yaml:"name"`
}

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](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html) .

TODO: EXAMPLE

type CfnApplicationProps 

type CfnApplicationProps struct {
	// Use this parameter to configure the application input.
	//
	// You can configure your application to receive input from a single streaming source. In this configuration, you map this streaming source to an in-application stream that is created. Your application code can then query the in-application stream like a table (you can think of it as a constantly updating table).
	//
	// For the streaming source, you provide its Amazon Resource Name (ARN) and format of data on the stream (for example, JSON, CSV, etc.). You also must provide an IAM role that Amazon Kinesis Analytics can assume to read this stream on your behalf.
	//
	// To create the in-application stream, you need to specify a schema to transform your data into a schematized version used in SQL. In the schema, you provide the necessary mapping of the data elements in the streaming source to record columns in the in-app stream.
	Inputs interface{} `json:"inputs" yaml:"inputs"`
	// One or more SQL statements that read input data, transform it, and generate output.
	//
	// For example, you can write a SQL statement that reads data from one in-application stream, generates a running average of the number of advertisement clicks by vendor, and insert resulting rows in another in-application stream using pumps. For more information about the typical pattern, see [Application Code](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-app-code.html) .
	//
	// You can provide such series of SQL statements, where output of one statement can be used as the input for the next statement. You store intermediate results by creating in-application streams and pumps.
	//
	// Note that the application code must create the streams with names specified in the `Outputs` . For example, if your `Outputs` defines output streams named `ExampleOutputStream1` and `ExampleOutputStream2` , then your application code must create these streams.
	ApplicationCode *string `json:"applicationCode" yaml:"applicationCode"`
	// Summary description of the application.
	ApplicationDescription *string `json:"applicationDescription" yaml:"applicationDescription"`
	// Name of your Amazon Kinesis Analytics application (for example, `sample-app` ).
	ApplicationName *string `json:"applicationName" yaml:"applicationName"`
}

Properties for defining a `CfnApplication`.

TODO: EXAMPLE

type CfnApplicationReferenceDataSource 

type CfnApplicationReferenceDataSource interface {
	awscdk.CfnResource
	awscdk.IInspectable
	ApplicationName() *string
	SetApplicationName(val *string)
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	LogicalId() *string
	Node() constructs.Node
	Ref() *string
	ReferenceDataSource() interface{}
	SetReferenceDataSource(val interface{})
	Stack() awscdk.Stack
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	ToString() *string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::KinesisAnalytics::ApplicationReferenceDataSource`.

Adds a reference data source to an existing application.

Amazon Kinesis Analytics reads reference data (that is, an Amazon S3 object) and creates an in-application table within your application. In the request, you provide the source (S3 bucket name and object key name), name of the in-application table to create, and the necessary mapping information that describes how data in Amazon S3 object maps to columns in the resulting in-application table.

For conceptual information, see [Configuring Application Input](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html) . For the limits on data sources you can add to your application, see [Limits](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html) .

This operation requires permissions to perform the `kinesisanalytics:AddApplicationOutput` action.

TODO: EXAMPLE

func NewCfnApplicationReferenceDataSource 

func NewCfnApplicationReferenceDataSource(scope constructs.Construct, id *string, props *CfnApplicationReferenceDataSourceProps) CfnApplicationReferenceDataSource

Create a new `AWS::KinesisAnalytics::ApplicationReferenceDataSource`.

type CfnApplicationReferenceDataSourceProps 

type CfnApplicationReferenceDataSourceProps struct {
	// Name of an existing application.
	ApplicationName *string `json:"applicationName" yaml:"applicationName"`
	// The reference data source can be an object in your Amazon S3 bucket.
	//
	// Amazon Kinesis Analytics reads the object and copies the data into the in-application table that is created. You provide an S3 bucket, object key name, and the resulting in-application table that is created. You must also provide an IAM role with the necessary permissions that Amazon Kinesis Analytics can assume to read the object from your S3 bucket on your behalf.
	ReferenceDataSource interface{} `json:"referenceDataSource" yaml:"referenceDataSource"`
}

Properties for defining a `CfnApplicationReferenceDataSource`.

TODO: EXAMPLE

type CfnApplicationReferenceDataSourceV2 

type CfnApplicationReferenceDataSourceV2 interface {
	awscdk.CfnResource
	awscdk.IInspectable
	ApplicationName() *string
	SetApplicationName(val *string)
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	LogicalId() *string
	Node() constructs.Node
	Ref() *string
	ReferenceDataSource() interface{}
	SetReferenceDataSource(val interface{})
	Stack() awscdk.Stack
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	ToString() *string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource`.

Adds a reference data source to an existing SQL-based Kinesis Data Analytics application.

Kinesis Data Analytics reads reference data (that is, an Amazon S3 object) and creates an in-application table within your application. In the request, you provide the source (S3 bucket name and object key name), name of the in-application table to create, and the necessary mapping information that describes how data in an Amazon S3 object maps to columns in the resulting in-application table.

TODO: EXAMPLE

func NewCfnApplicationReferenceDataSourceV2 

func NewCfnApplicationReferenceDataSourceV2(scope constructs.Construct, id *string, props *CfnApplicationReferenceDataSourceV2Props) CfnApplicationReferenceDataSourceV2

Create a new `AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource`.

type CfnApplicationReferenceDataSourceV2Props 

type CfnApplicationReferenceDataSourceV2Props struct {
	// The name of the application.
	ApplicationName *string `json:"applicationName" yaml:"applicationName"`
	// For a SQL-based Kinesis Data Analytics application, describes the reference data source by providing the source information (Amazon S3 bucket name and object key name), the resulting in-application table name that is created, and the necessary schema to map the data elements in the Amazon S3 object to the in-application table.
	ReferenceDataSource interface{} `json:"referenceDataSource" yaml:"referenceDataSource"`
}

Properties for defining a `CfnApplicationReferenceDataSourceV2`.

TODO: EXAMPLE

type CfnApplicationReferenceDataSourceV2_CSVMappingParametersProperty 

type CfnApplicationReferenceDataSourceV2_CSVMappingParametersProperty struct {
	// The column delimiter.
	//
	// For example, in a CSV format, a comma (",") is the typical column delimiter.
	RecordColumnDelimiter *string `json:"recordColumnDelimiter" yaml:"recordColumnDelimiter"`
	// The row delimiter.
	//
	// For example, in a CSV format, *'\n'* is the typical row delimiter.
	RecordRowDelimiter *string `json:"recordRowDelimiter" yaml:"recordRowDelimiter"`
}

For a SQL-based Kinesis Data Analytics application, provides additional mapping information when the record format uses delimiters, such as CSV.

For example, the following sample records use CSV format, where the records use the *'\n'* as the row delimiter and a comma (",") as the column delimiter:

`"name1", "address1"`

`"name2", "address2"`

TODO: EXAMPLE

type CfnApplicationReferenceDataSourceV2_JSONMappingParametersProperty 

type CfnApplicationReferenceDataSourceV2_JSONMappingParametersProperty struct {
	// The path to the top-level parent that contains the records.
	RecordRowPath *string `json:"recordRowPath" yaml:"recordRowPath"`
}

For a SQL-based Kinesis Data Analytics application, provides additional mapping information when JSON is the record format on the streaming source.

TODO: EXAMPLE

type CfnApplicationReferenceDataSourceV2_MappingParametersProperty 

type CfnApplicationReferenceDataSourceV2_MappingParametersProperty struct {
	// Provides additional mapping information when the record format uses delimiters (for example, CSV).
	CsvMappingParameters interface{} `json:"csvMappingParameters" yaml:"csvMappingParameters"`
	// Provides additional mapping information when JSON is the record format on the streaming source.
	JsonMappingParameters interface{} `json:"jsonMappingParameters" yaml:"jsonMappingParameters"`
}

When you configure a SQL-based Kinesis Data Analytics application's input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.

TODO: EXAMPLE

type CfnApplicationReferenceDataSourceV2_RecordColumnProperty 

type CfnApplicationReferenceDataSourceV2_RecordColumnProperty struct {
	// The name of the column that is created in the in-application input stream or reference table.
	Name *string `json:"name" yaml:"name"`
	// The type of column created in the in-application input stream or reference table.
	SqlType *string `json:"sqlType" yaml:"sqlType"`
	// A reference to the data element in the streaming input or the reference data source.
	Mapping *string `json:"mapping" yaml:"mapping"`
}

For a SQL-based Kinesis Data Analytics application, describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

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

TODO: EXAMPLE

type CfnApplicationReferenceDataSourceV2_RecordFormatProperty 

type CfnApplicationReferenceDataSourceV2_RecordFormatProperty struct {
	// The type of record format.
	RecordFormatType *string `json:"recordFormatType" yaml:"recordFormatType"`
	// When you configure application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
	MappingParameters interface{} `json:"mappingParameters" yaml:"mappingParameters"`
}

For a SQL-based Kinesis Data Analytics application, describes the record format and relevant mapping information that should be applied to schematize the records on the stream.

TODO: EXAMPLE

type CfnApplicationReferenceDataSourceV2_ReferenceDataSourceProperty 

type CfnApplicationReferenceDataSourceV2_ReferenceDataSourceProperty struct {
	// Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
	ReferenceSchema interface{} `json:"referenceSchema" yaml:"referenceSchema"`
	// Identifies the S3 bucket and object that contains the reference data.
	//
	// A Kinesis Data Analytics application loads reference data only once. If the data changes, you call the [UpdateApplication](https://docs.aws.amazon.com/kinesisanalytics/latest/apiv2/API_UpdateApplication.html) operation to trigger reloading of data into your application.
	S3ReferenceDataSource interface{} `json:"s3ReferenceDataSource" yaml:"s3ReferenceDataSource"`
	// The name of the in-application table to create.
	TableName *string `json:"tableName" yaml:"tableName"`
}

For a SQL-based Kinesis Data Analytics application, describes the reference data source by providing the source information (Amazon S3 bucket name and object key name), the resulting in-application table name that is created, and the necessary schema to map the data elements in the Amazon S3 object to the in-application table.

TODO: EXAMPLE

type CfnApplicationReferenceDataSourceV2_ReferenceSchemaProperty 

type CfnApplicationReferenceDataSourceV2_ReferenceSchemaProperty struct {
	// A list of `RecordColumn` objects.
	RecordColumns interface{} `json:"recordColumns" yaml:"recordColumns"`
	// Specifies the format of the records on the streaming source.
	RecordFormat interface{} `json:"recordFormat" yaml:"recordFormat"`
	// Specifies the encoding of the records in the streaming source.
	//
	// For example, UTF-8.
	RecordEncoding *string `json:"recordEncoding" yaml:"recordEncoding"`
}

For a SQL-based Kinesis Data Analytics application, describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

TODO: EXAMPLE

type CfnApplicationReferenceDataSourceV2_S3ReferenceDataSourceProperty 

type CfnApplicationReferenceDataSourceV2_S3ReferenceDataSourceProperty struct {
	// The Amazon Resource Name (ARN) of the S3 bucket.
	BucketArn *string `json:"bucketArn" yaml:"bucketArn"`
	// The object key name containing the reference data.
	FileKey *string `json:"fileKey" yaml:"fileKey"`
}

For an SQL-based Amazon Kinesis Data Analytics application, identifies the Amazon S3 bucket and object that contains the reference data.

A Kinesis Data Analytics application loads reference data only once. If the data changes, you call the [UpdateApplication](https://docs.aws.amazon.com/kinesisanalytics/latest/apiv2/API_UpdateApplication.html) operation to trigger reloading of data into your application.

TODO: EXAMPLE

type CfnApplicationReferenceDataSource_CSVMappingParametersProperty 

type CfnApplicationReferenceDataSource_CSVMappingParametersProperty struct {
	// Column delimiter.
	//
	// For example, in a CSV format, a comma (",") is the typical column delimiter.
	RecordColumnDelimiter *string `json:"recordColumnDelimiter" yaml:"recordColumnDelimiter"`
	// Row delimiter.
	//
	// For example, in a CSV format, *'\n'* is the typical row delimiter.
	RecordRowDelimiter *string `json:"recordRowDelimiter" yaml:"recordRowDelimiter"`
}

Provides additional mapping information when the record format uses delimiters, such as CSV.

For example, the following sample records use CSV format, where the records use the *'\n'* as the row delimiter and a comma (",") as the column delimiter:

`"name1", "address1"`

`"name2", "address2"`

TODO: EXAMPLE

type CfnApplicationReferenceDataSource_JSONMappingParametersProperty 

type CfnApplicationReferenceDataSource_JSONMappingParametersProperty struct {
	// Path to the top-level parent that contains the records.
	RecordRowPath *string `json:"recordRowPath" yaml:"recordRowPath"`
}

Provides additional mapping information when JSON is the record format on the streaming source.

TODO: EXAMPLE

type CfnApplicationReferenceDataSource_MappingParametersProperty 

type CfnApplicationReferenceDataSource_MappingParametersProperty struct {
	// Provides additional mapping information when the record format uses delimiters (for example, CSV).
	CsvMappingParameters interface{} `json:"csvMappingParameters" yaml:"csvMappingParameters"`
	// Provides additional mapping information when JSON is the record format on the streaming source.
	JsonMappingParameters interface{} `json:"jsonMappingParameters" yaml:"jsonMappingParameters"`
}

When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.

TODO: EXAMPLE

type CfnApplicationReferenceDataSource_RecordColumnProperty 

type CfnApplicationReferenceDataSource_RecordColumnProperty struct {
	// Name of the column created in the in-application input stream or reference table.
	Name *string `json:"name" yaml:"name"`
	// Type of column created in the in-application input stream or reference table.
	SqlType *string `json:"sqlType" yaml:"sqlType"`
	// Reference to the data element in the streaming input or the reference data source.
	//
	// This element is required if the [RecordFormatType](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/API_RecordFormat.html#analytics-Type-RecordFormat-RecordFormatTypel) is `JSON` .
	Mapping *string `json:"mapping" yaml:"mapping"`
}

Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

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

TODO: EXAMPLE

type CfnApplicationReferenceDataSource_RecordFormatProperty 

type CfnApplicationReferenceDataSource_RecordFormatProperty struct {
	// The type of record format.
	RecordFormatType *string `json:"recordFormatType" yaml:"recordFormatType"`
	// When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
	MappingParameters interface{} `json:"mappingParameters" yaml:"mappingParameters"`
}

Describes the record format and relevant mapping information that should be applied to schematize the records on the stream.

TODO: EXAMPLE

type CfnApplicationReferenceDataSource_ReferenceDataSourceProperty 

type CfnApplicationReferenceDataSource_ReferenceDataSourceProperty struct {
	// Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
	ReferenceSchema interface{} `json:"referenceSchema" yaml:"referenceSchema"`
	// Identifies the S3 bucket and object that contains the reference data.
	//
	// Also identifies the IAM role Amazon Kinesis Analytics can assume to read this object on your behalf. An Amazon Kinesis Analytics application loads reference data only once. If the data changes, you call the `UpdateApplication` operation to trigger reloading of data into your application.
	S3ReferenceDataSource interface{} `json:"s3ReferenceDataSource" yaml:"s3ReferenceDataSource"`
	// Name of the in-application table to create.
	TableName *string `json:"tableName" yaml:"tableName"`
}

Describes the reference data source by providing the source information (S3 bucket name and object key name), the resulting in-application table name that is created, and the necessary schema to map the data elements in the Amazon S3 object to the in-application table.

TODO: EXAMPLE

type CfnApplicationReferenceDataSource_ReferenceSchemaProperty 

type CfnApplicationReferenceDataSource_ReferenceSchemaProperty struct {
	// A list of RecordColumn objects.
	RecordColumns interface{} `json:"recordColumns" yaml:"recordColumns"`
	// Specifies the format of the records on the reference source.
	RecordFormat interface{} `json:"recordFormat" yaml:"recordFormat"`
	// Specifies the encoding of the records in the reference source.
	//
	// For example, UTF-8.
	RecordEncoding *string `json:"recordEncoding" yaml:"recordEncoding"`
}

The ReferenceSchema property type specifies the format of the data in the reference source for a SQL-based Amazon Kinesis Data Analytics application.

TODO: EXAMPLE

type CfnApplicationReferenceDataSource_S3ReferenceDataSourceProperty 

type CfnApplicationReferenceDataSource_S3ReferenceDataSourceProperty struct {
	// Amazon Resource Name (ARN) of the S3 bucket.
	BucketArn *string `json:"bucketArn" yaml:"bucketArn"`
	// Object key name containing reference data.
	FileKey *string `json:"fileKey" yaml:"fileKey"`
	// ARN of the IAM role that the service can assume to read data on your behalf.
	//
	// This role must have permission for the `s3:GetObject` action on the object and trust policy that allows Amazon Kinesis Analytics service principal to assume this role.
	ReferenceRoleArn *string `json:"referenceRoleArn" yaml:"referenceRoleArn"`
}

Identifies the S3 bucket and object that contains the reference data.

Also identifies the IAM role Amazon Kinesis Analytics can assume to read this object on your behalf.

An Amazon Kinesis Analytics application loads reference data only once. If the data changes, you call the [UpdateApplication](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/API_UpdateApplication.html) operation to trigger reloading of data into your application.

TODO: EXAMPLE

type CfnApplicationV2 

type CfnApplicationV2 interface {
	awscdk.CfnResource
	awscdk.IInspectable
	ApplicationConfiguration() interface{}
	SetApplicationConfiguration(val interface{})
	ApplicationDescription() *string
	SetApplicationDescription(val *string)
	ApplicationMode() *string
	SetApplicationMode(val *string)
	ApplicationName() *string
	SetApplicationName(val *string)
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	LogicalId() *string
	Node() constructs.Node
	Ref() *string
	RuntimeEnvironment() *string
	SetRuntimeEnvironment(val *string)
	ServiceExecutionRole() *string
	SetServiceExecutionRole(val *string)
	Stack() awscdk.Stack
	Tags() awscdk.TagManager
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	ToString() *string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::KinesisAnalyticsV2::Application`.

Creates an Amazon Kinesis Data Analytics application. For information about creating a Kinesis Data Analytics application, see [Creating an Application](https://docs.aws.amazon.com/kinesisanalytics/latest/java/getting-started.html) .

TODO: EXAMPLE

func NewCfnApplicationV2 

func NewCfnApplicationV2(scope constructs.Construct, id *string, props *CfnApplicationV2Props) CfnApplicationV2

Create a new `AWS::KinesisAnalyticsV2::Application`.

type CfnApplicationV2Props 

type CfnApplicationV2Props struct {
	// The runtime environment for the application.
	RuntimeEnvironment *string `json:"runtimeEnvironment" yaml:"runtimeEnvironment"`
	// Specifies the IAM role that the application uses to access external resources.
	ServiceExecutionRole *string `json:"serviceExecutionRole" yaml:"serviceExecutionRole"`
	// Use this parameter to configure the application.
	ApplicationConfiguration interface{} `json:"applicationConfiguration" yaml:"applicationConfiguration"`
	// The description of the application.
	ApplicationDescription *string `json:"applicationDescription" yaml:"applicationDescription"`
	// To create a Kinesis Data Analytics Studio notebook, you must set the mode to `INTERACTIVE` .
	//
	// However, for a Kinesis Data Analytics for Apache Flink application, the mode is optional.
	ApplicationMode *string `json:"applicationMode" yaml:"applicationMode"`
	// The name of the application.
	ApplicationName *string `json:"applicationName" yaml:"applicationName"`
	// A list of one or more tags to assign to the application.
	//
	// A tag is a key-value pair that identifies an application. Note that the maximum number of application tags includes system tags. The maximum number of user-defined application tags is 50.
	Tags *[]*awscdk.CfnTag `json:"tags" yaml:"tags"`
}

Properties for defining a `CfnApplicationV2`.

TODO: EXAMPLE

type CfnApplicationV2_ApplicationCodeConfigurationProperty 

type CfnApplicationV2_ApplicationCodeConfigurationProperty struct {
	// The location and type of the application code.
	CodeContent interface{} `json:"codeContent" yaml:"codeContent"`
	// Specifies whether the code content is in text or zip format.
	CodeContentType *string `json:"codeContentType" yaml:"codeContentType"`
}

Describes code configuration for an application.

TODO: EXAMPLE

type CfnApplicationV2_ApplicationConfigurationProperty 

type CfnApplicationV2_ApplicationConfigurationProperty struct {
	// The code location and type parameters for a Flink-based Kinesis Data Analytics application.
	ApplicationCodeConfiguration interface{} `json:"applicationCodeConfiguration" yaml:"applicationCodeConfiguration"`
	// Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
	ApplicationSnapshotConfiguration interface{} `json:"applicationSnapshotConfiguration" yaml:"applicationSnapshotConfiguration"`
	// Describes execution properties for a Flink-based Kinesis Data Analytics application.
	EnvironmentProperties interface{} `json:"environmentProperties" yaml:"environmentProperties"`
	// The creation and update parameters for a Flink-based Kinesis Data Analytics application.
	FlinkApplicationConfiguration interface{} `json:"flinkApplicationConfiguration" yaml:"flinkApplicationConfiguration"`
	// The creation and update parameters for a SQL-based Kinesis Data Analytics application.
	SqlApplicationConfiguration interface{} `json:"sqlApplicationConfiguration" yaml:"sqlApplicationConfiguration"`
	// The configuration parameters for a Kinesis Data Analytics Studio notebook.
	ZeppelinApplicationConfiguration interface{} `json:"zeppelinApplicationConfiguration" yaml:"zeppelinApplicationConfiguration"`
}

Specifies the creation parameters for a Kinesis Data Analytics application.

TODO: EXAMPLE

type CfnApplicationV2_ApplicationSnapshotConfigurationProperty 

type CfnApplicationV2_ApplicationSnapshotConfigurationProperty struct {
	// Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
	SnapshotsEnabled interface{} `json:"snapshotsEnabled" yaml:"snapshotsEnabled"`
}

Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.

TODO: EXAMPLE

type CfnApplicationV2_CSVMappingParametersProperty 

type CfnApplicationV2_CSVMappingParametersProperty struct {
	// The column delimiter.
	//
	// For example, in a CSV format, a comma (",") is the typical column delimiter.
	RecordColumnDelimiter *string `json:"recordColumnDelimiter" yaml:"recordColumnDelimiter"`
	// The row delimiter.
	//
	// For example, in a CSV format, *'\n'* is the typical row delimiter.
	RecordRowDelimiter *string `json:"recordRowDelimiter" yaml:"recordRowDelimiter"`
}

For a SQL-based Kinesis Data Analytics application, provides additional mapping information when the record format uses delimiters, such as CSV.

For example, the following sample records use CSV format, where the records use the *'\n'* as the row delimiter and a comma (",") as the column delimiter:

`"name1", "address1"`

`"name2", "address2"`

TODO: EXAMPLE

type CfnApplicationV2_CatalogConfigurationProperty 

type CfnApplicationV2_CatalogConfigurationProperty struct {
	// The configuration parameters for the default Amazon Glue database.
	//
	// You use this database for Apache Flink SQL queries and table API transforms that you write in a Kinesis Data Analytics Studio notebook.
	GlueDataCatalogConfiguration interface{} `json:"glueDataCatalogConfiguration" yaml:"glueDataCatalogConfiguration"`
}

The configuration parameters for the default Amazon Glue database.

You use this database for SQL queries that you write in a Kinesis Data Analytics Studio notebook.

TODO: EXAMPLE

type CfnApplicationV2_CheckpointConfigurationProperty 

type CfnApplicationV2_CheckpointConfigurationProperty struct {
	// Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior.
	//
	// You must set this property to `CUSTOM` in order to set the `CheckpointingEnabled` , `CheckpointInterval` , or `MinPauseBetweenCheckpoints` parameters.
	//
	// > If this value is set to `DEFAULT` , the application will use the following values, even if they are set to other values using APIs or application code:
	// >
	// > - *CheckpointingEnabled:* true
	// > - *CheckpointInterval:* 60000
	// > - *MinPauseBetweenCheckpoints:* 5000
	ConfigurationType *string `json:"configurationType" yaml:"configurationType"`
	// Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
	//
	// > If `CheckpointConfiguration.ConfigurationType` is `DEFAULT` , the application will use a `CheckpointingEnabled` value of `true` , even if this value is set to another value using this API or in application code.
	CheckpointingEnabled interface{} `json:"checkpointingEnabled" yaml:"checkpointingEnabled"`
	// Describes the interval in milliseconds between checkpoint operations.
	//
	// > If `CheckpointConfiguration.ConfigurationType` is `DEFAULT` , the application will use a `CheckpointInterval` value of 60000, even if this value is set to another value using this API or in application code.
	CheckpointInterval *float64 `json:"checkpointInterval" yaml:"checkpointInterval"`
	// Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
	//
	// If a checkpoint operation takes longer than the `CheckpointInterval` , the application otherwise performs continual checkpoint operations. For more information, see [Tuning Checkpointing](https://docs.aws.amazon.com/https://ci.apache.org/projects/flink/flink-docs-release-1.8/ops/state/large_state_tuning.html#tuning-checkpointing) in the [Apache Flink Documentation](https://docs.aws.amazon.com/https://ci.apache.org/projects/flink/flink-docs-release-1.8/) .
	//
	// > If `CheckpointConfiguration.ConfigurationType` is `DEFAULT` , the application will use a `MinPauseBetweenCheckpoints` value of 5000, even if this value is set using this API or in application code.
	MinPauseBetweenCheckpoints *float64 `json:"minPauseBetweenCheckpoints" yaml:"minPauseBetweenCheckpoints"`
}

Describes an application's checkpointing configuration.

Checkpointing is the process of persisting application state for fault tolerance. For more information, see [Checkpoints for Fault Tolerance](https://docs.aws.amazon.com/https://ci.apache.org/projects/flink/flink-docs-release-1.8/concepts/programming-model.html#checkpoints-for-fault-tolerance) in the [Apache Flink Documentation](https://docs.aws.amazon.com/https://ci.apache.org/projects/flink/flink-docs-release-1.8/) .

TODO: EXAMPLE

type CfnApplicationV2_CodeContentProperty 

type CfnApplicationV2_CodeContentProperty struct {
	// Information about the Amazon S3 bucket that contains the application code.
	S3ContentLocation interface{} `json:"s3ContentLocation" yaml:"s3ContentLocation"`
	// The text-format code for a Flink-based Kinesis Data Analytics application.
	TextContent *string `json:"textContent" yaml:"textContent"`
	// The zip-format code for a Flink-based Kinesis Data Analytics application.
	ZipFileContent *string `json:"zipFileContent" yaml:"zipFileContent"`
}

Specifies either the application code, or the location of the application code, for a Flink-based Kinesis Data Analytics application.

TODO: EXAMPLE

type CfnApplicationV2_CustomArtifactConfigurationProperty 

type CfnApplicationV2_CustomArtifactConfigurationProperty struct {
	// Set this to either `UDF` or `DEPENDENCY_JAR` .
	//
	// `UDF` stands for user-defined functions. This type of artifact must be in an S3 bucket. A `DEPENDENCY_JAR` can be in either Maven or an S3 bucket.
	ArtifactType *string `json:"artifactType" yaml:"artifactType"`
	// The parameters required to fully specify a Maven reference.
	MavenReference interface{} `json:"mavenReference" yaml:"mavenReference"`
	// The location of the custom artifacts.
	S3ContentLocation interface{} `json:"s3ContentLocation" yaml:"s3ContentLocation"`
}

The configuration of connectors and user-defined functions.

TODO: EXAMPLE

type CfnApplicationV2_DeployAsApplicationConfigurationProperty 

type CfnApplicationV2_DeployAsApplicationConfigurationProperty struct {
	// The description of an Amazon S3 object that contains the Amazon Data Analytics application, including the Amazon Resource Name (ARN) of the S3 bucket, the name of the Amazon S3 object that contains the data, and the version number of the Amazon S3 object that contains the data.
	S3ContentLocation interface{} `json:"s3ContentLocation" yaml:"s3ContentLocation"`
}

The information required to deploy a Kinesis Data Analytics Studio notebook as an application with durable state.

TODO: EXAMPLE

type CfnApplicationV2_EnvironmentPropertiesProperty 

type CfnApplicationV2_EnvironmentPropertiesProperty struct {
	// Describes the execution property groups.
	PropertyGroups interface{} `json:"propertyGroups" yaml:"propertyGroups"`
}

Describes execution properties for a Flink-based Kinesis Data Analytics application.

TODO: EXAMPLE

type CfnApplicationV2_FlinkApplicationConfigurationProperty 

type CfnApplicationV2_FlinkApplicationConfigurationProperty struct {
	// Describes an application's checkpointing configuration.
	//
	// Checkpointing is the process of persisting application state for fault tolerance. For more information, see [Checkpoints for Fault Tolerance](https://docs.aws.amazon.com/https://ci.apache.org/projects/flink/flink-docs-release-1.8/concepts/programming-model.html#checkpoints-for-fault-tolerance) in the [Apache Flink Documentation](https://docs.aws.amazon.com/https://ci.apache.org/projects/flink/flink-docs-release-1.8/) .
	CheckpointConfiguration interface{} `json:"checkpointConfiguration" yaml:"checkpointConfiguration"`
	// Describes configuration parameters for Amazon CloudWatch logging for an application.
	MonitoringConfiguration interface{} `json:"monitoringConfiguration" yaml:"monitoringConfiguration"`
	// Describes parameters for how an application executes multiple tasks simultaneously.
	ParallelismConfiguration interface{} `json:"parallelismConfiguration" yaml:"parallelismConfiguration"`
}

Describes configuration parameters for a Flink-based Kinesis Data Analytics application or a Studio notebook.

TODO: EXAMPLE

type CfnApplicationV2_GlueDataCatalogConfigurationProperty 

type CfnApplicationV2_GlueDataCatalogConfigurationProperty struct {
	// The Amazon Resource Name (ARN) of the database.
	DatabaseArn *string `json:"databaseArn" yaml:"databaseArn"`
}

The configuration of the Glue Data Catalog that you use for Apache Flink SQL queries and table API transforms that you write in an application.

TODO: EXAMPLE

type CfnApplicationV2_InputLambdaProcessorProperty 

type CfnApplicationV2_InputLambdaProcessorProperty struct {
	// The ARN of the Amazon Lambda function that operates on records in the stream.
	//
	// > To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see [Example ARNs: Amazon Lambda](https://docs.aws.amazon.com//general/latest/gr/aws-arns-and-namespaces.html#arn-syntax-lambda)
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
}

An object that contains the Amazon Resource Name (ARN) of the Amazon Lambda function that is used to preprocess records in the stream in a SQL-based Kinesis Data Analytics application.

TODO: EXAMPLE

type CfnApplicationV2_InputParallelismProperty 

type CfnApplicationV2_InputParallelismProperty struct {
	// The number of in-application streams to create.
	Count *float64 `json:"count" yaml:"count"`
}

For a SQL-based Kinesis Data Analytics application, describes the number of in-application streams to create for a given streaming source.

TODO: EXAMPLE

type CfnApplicationV2_InputProcessingConfigurationProperty 

type CfnApplicationV2_InputProcessingConfigurationProperty struct {
	// The [InputLambdaProcessor](https://docs.aws.amazon.com/kinesisanalytics/latest/apiv2/API_InputLambdaProcessor.html) that is used to preprocess the records in the stream before being processed by your application code.
	InputLambdaProcessor interface{} `json:"inputLambdaProcessor" yaml:"inputLambdaProcessor"`
}

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](https://docs.aws.amazon.com/lambda/) .

TODO: EXAMPLE

type CfnApplicationV2_InputProperty 

type CfnApplicationV2_InputProperty struct {
	// 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.
	//
	// Also used to describe the format of the reference data source.
	InputSchema interface{} `json:"inputSchema" yaml:"inputSchema"`
	// The name prefix to use when creating an in-application stream.
	//
	// 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.
	NamePrefix *string `json:"namePrefix" yaml:"namePrefix"`
	// Describes the number of in-application streams to create.
	InputParallelism interface{} `json:"inputParallelism" yaml:"inputParallelism"`
	// The [InputProcessingConfiguration](https://docs.aws.amazon.com/kinesisanalytics/latest/apiv2/API_InputProcessingConfiguration.html) 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](https://docs.aws.amazon.com/kinesisanalytics/latest/apiv2/API_InputLambdaProcessor.html) .
	InputProcessingConfiguration interface{} `json:"inputProcessingConfiguration" yaml:"inputProcessingConfiguration"`
	// If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
	KinesisFirehoseInput interface{} `json:"kinesisFirehoseInput" yaml:"kinesisFirehoseInput"`
	// If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
	KinesisStreamsInput interface{} `json:"kinesisStreamsInput" yaml:"kinesisStreamsInput"`
}

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.

TODO: EXAMPLE

type CfnApplicationV2_InputSchemaProperty 

type CfnApplicationV2_InputSchemaProperty struct {
	// A list of `RecordColumn` objects.
	RecordColumns interface{} `json:"recordColumns" yaml:"recordColumns"`
	// Specifies the format of the records on the streaming source.
	RecordFormat interface{} `json:"recordFormat" yaml:"recordFormat"`
	// Specifies the encoding of the records in the streaming source.
	//
	// For example, UTF-8.
	RecordEncoding *string `json:"recordEncoding" yaml:"recordEncoding"`
}

For a SQL-based Kinesis Data Analytics application, describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

TODO: EXAMPLE

type CfnApplicationV2_JSONMappingParametersProperty 

type CfnApplicationV2_JSONMappingParametersProperty struct {
	// The path to the top-level parent that contains the records.
	RecordRowPath *string `json:"recordRowPath" yaml:"recordRowPath"`
}

For a SQL-based Kinesis Data Analytics application, provides additional mapping information when JSON is the record format on the streaming source.

TODO: EXAMPLE

type CfnApplicationV2_KinesisFirehoseInputProperty 

type CfnApplicationV2_KinesisFirehoseInputProperty struct {
	// The Amazon Resource Name (ARN) of the delivery stream.
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
}

For a SQL-based Kinesis Data Analytics application, identifies a Kinesis Data Firehose delivery stream as the streaming source.

You provide the delivery stream's Amazon Resource Name (ARN).

TODO: EXAMPLE

type CfnApplicationV2_KinesisStreamsInputProperty 

type CfnApplicationV2_KinesisStreamsInputProperty struct {
	// The ARN of the input Kinesis data stream to read.
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
}

Identifies a Kinesis data stream as the streaming source.

You provide the stream's Amazon Resource Name (ARN).

TODO: EXAMPLE

type CfnApplicationV2_MappingParametersProperty 

type CfnApplicationV2_MappingParametersProperty struct {
	// Provides additional mapping information when the record format uses delimiters (for example, CSV).
	CsvMappingParameters interface{} `json:"csvMappingParameters" yaml:"csvMappingParameters"`
	// Provides additional mapping information when JSON is the record format on the streaming source.
	JsonMappingParameters interface{} `json:"jsonMappingParameters" yaml:"jsonMappingParameters"`
}

When you configure a SQL-based Kinesis Data Analytics application's input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.

TODO: EXAMPLE

type CfnApplicationV2_MavenReferenceProperty 

type CfnApplicationV2_MavenReferenceProperty struct {
	// The artifact ID of the Maven reference.
	ArtifactId *string `json:"artifactId" yaml:"artifactId"`
	// The group ID of the Maven reference.
	GroupId *string `json:"groupId" yaml:"groupId"`
	// The version of the Maven reference.
	Version *string `json:"version" yaml:"version"`
}

The information required to specify a Maven reference.

You can use Maven references to specify dependency JAR files.

TODO: EXAMPLE

type CfnApplicationV2_MonitoringConfigurationProperty 

type CfnApplicationV2_MonitoringConfigurationProperty struct {
	// Describes whether to use the default CloudWatch logging configuration for an application.
	//
	// You must set this property to `CUSTOM` in order to set the `LogLevel` or `MetricsLevel` parameters.
	ConfigurationType *string `json:"configurationType" yaml:"configurationType"`
	// Describes the verbosity of the CloudWatch Logs for an application.
	LogLevel *string `json:"logLevel" yaml:"logLevel"`
	// Describes the granularity of the CloudWatch Logs for an application.
	//
	// The `Parallelism` level is not recommended for applications with a Parallelism over 64 due to excessive costs.
	MetricsLevel *string `json:"metricsLevel" yaml:"metricsLevel"`
}

Describes configuration parameters for Amazon CloudWatch logging for a Java-based Kinesis Data Analytics application.

For more information about CloudWatch logging, see [Monitoring](https://docs.aws.amazon.com/kinesisanalytics/latest/java/monitoring-overview) .

TODO: EXAMPLE

type CfnApplicationV2_ParallelismConfigurationProperty 

type CfnApplicationV2_ParallelismConfigurationProperty struct {
	// Describes whether the application uses the default parallelism for the Kinesis Data Analytics service.
	//
	// You must set this property to `CUSTOM` in order to change your application's `AutoScalingEnabled` , `Parallelism` , or `ParallelismPerKPU` properties.
	ConfigurationType *string `json:"configurationType" yaml:"configurationType"`
	// Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
	AutoScalingEnabled interface{} `json:"autoScalingEnabled" yaml:"autoScalingEnabled"`
	// Describes the initial number of parallel tasks that a Java-based Kinesis Data Analytics application can perform.
	//
	// The Kinesis Data Analytics service can increase this number automatically if [ParallelismConfiguration:AutoScalingEnabled](https://docs.aws.amazon.com/kinesisanalytics/latest/apiv2/API_ParallelismConfiguration.html#kinesisanalytics-Type-ParallelismConfiguration-AutoScalingEnabled.html) is set to `true` .
	Parallelism *float64 `json:"parallelism" yaml:"parallelism"`
	// Describes the number of parallel tasks that a Java-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
	//
	// For more information about KPUs, see [Amazon Kinesis Data Analytics Pricing](https://docs.aws.amazon.com/kinesis/data-analytics/pricing/) .
	ParallelismPerKpu *float64 `json:"parallelismPerKpu" yaml:"parallelismPerKpu"`
}

Describes parameters for how a Flink-based Kinesis Data Analytics application executes multiple tasks simultaneously.

For more information about parallelism, see [Parallel Execution](https://docs.aws.amazon.com/https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/parallel.html) in the [Apache Flink Documentation](https://docs.aws.amazon.com/https://ci.apache.org/projects/flink/flink-docs-release-1.8/) .

TODO: EXAMPLE

type CfnApplicationV2_PropertyGroupProperty 

type CfnApplicationV2_PropertyGroupProperty struct {
	// Describes the key of an application execution property key-value pair.
	PropertyGroupId *string `json:"propertyGroupId" yaml:"propertyGroupId"`
	// Describes the value of an application execution property key-value pair.
	PropertyMap interface{} `json:"propertyMap" yaml:"propertyMap"`
}

Property key-value pairs passed into an application.

TODO: EXAMPLE

type CfnApplicationV2_RecordColumnProperty 

type CfnApplicationV2_RecordColumnProperty struct {
	// The name of the column that is created in the in-application input stream or reference table.
	Name *string `json:"name" yaml:"name"`
	// The type of column created in the in-application input stream or reference table.
	SqlType *string `json:"sqlType" yaml:"sqlType"`
	// A reference to the data element in the streaming input or the reference data source.
	Mapping *string `json:"mapping" yaml:"mapping"`
}

For a SQL-based Kinesis Data Analytics application, describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

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

TODO: EXAMPLE

type CfnApplicationV2_RecordFormatProperty 

type CfnApplicationV2_RecordFormatProperty struct {
	// The type of record format.
	RecordFormatType *string `json:"recordFormatType" yaml:"recordFormatType"`
	// When you configure application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
	MappingParameters interface{} `json:"mappingParameters" yaml:"mappingParameters"`
}

For a SQL-based Kinesis Data Analytics application, describes the record format and relevant mapping information that should be applied to schematize the records on the stream.

TODO: EXAMPLE

type CfnApplicationV2_S3ContentBaseLocationProperty 

type CfnApplicationV2_S3ContentBaseLocationProperty struct {
	// The base path for the S3 bucket.
	BasePath *string `json:"basePath" yaml:"basePath"`
	// The Amazon Resource Name (ARN) of the S3 bucket.
	BucketArn *string `json:"bucketArn" yaml:"bucketArn"`
}

The base location of the Amazon Data Analytics application.

TODO: EXAMPLE

type CfnApplicationV2_S3ContentLocationProperty 

type CfnApplicationV2_S3ContentLocationProperty struct {
	// The Amazon Resource Name (ARN) for the S3 bucket containing the application code.
	BucketArn *string `json:"bucketArn" yaml:"bucketArn"`
	// The file key for the object containing the application code.
	FileKey *string `json:"fileKey" yaml:"fileKey"`
	// The version of the object containing the application code.
	ObjectVersion *string `json:"objectVersion" yaml:"objectVersion"`
}

The location of an application or a custom artifact.

TODO: EXAMPLE

type CfnApplicationV2_SqlApplicationConfigurationProperty 

type CfnApplicationV2_SqlApplicationConfigurationProperty struct {
	// The array of [Input](https://docs.aws.amazon.com/kinesisanalytics/latest/apiv2/API_Input.html) objects describing the input streams used by the application.
	Inputs interface{} `json:"inputs" yaml:"inputs"`
}

Describes the inputs, outputs, and reference data sources for a SQL-based Kinesis Data Analytics application.

TODO: EXAMPLE

type CfnApplicationV2_ZeppelinApplicationConfigurationProperty 

type CfnApplicationV2_ZeppelinApplicationConfigurationProperty struct {
	// The Amazon Glue Data Catalog that you use in queries in a Kinesis Data Analytics Studio notebook.
	CatalogConfiguration interface{} `json:"catalogConfiguration" yaml:"catalogConfiguration"`
	// A list of `CustomArtifactConfiguration` objects.
	CustomArtifactsConfiguration interface{} `json:"customArtifactsConfiguration" yaml:"customArtifactsConfiguration"`
	// The information required to deploy a Kinesis Data Analytics Studio notebook as an application with durable state.
	DeployAsApplicationConfiguration interface{} `json:"deployAsApplicationConfiguration" yaml:"deployAsApplicationConfiguration"`
	// The monitoring configuration of a Kinesis Data Analytics Studio notebook.
	MonitoringConfiguration interface{} `json:"monitoringConfiguration" yaml:"monitoringConfiguration"`
}

The configuration of a Kinesis Data Analytics Studio notebook.

TODO: EXAMPLE

type CfnApplicationV2_ZeppelinMonitoringConfigurationProperty 

type CfnApplicationV2_ZeppelinMonitoringConfigurationProperty struct {
	// The verbosity of the CloudWatch Logs for an application.
	//
	// You can set it to `INFO` , `WARN` , `ERROR` , or `DEBUG` .
	LogLevel *string `json:"logLevel" yaml:"logLevel"`
}

Describes configuration parameters for Amazon CloudWatch logging for a Kinesis Data Analytics Studio notebook.

For more information about CloudWatch logging, see [Monitoring](https://docs.aws.amazon.com/kinesisanalytics/latest/java/monitoring-overview.html) .

TODO: EXAMPLE

type CfnApplication_CSVMappingParametersProperty 

type CfnApplication_CSVMappingParametersProperty struct {
	// Column delimiter.
	//
	// For example, in a CSV format, a comma (",") is the typical column delimiter.
	RecordColumnDelimiter *string `json:"recordColumnDelimiter" yaml:"recordColumnDelimiter"`
	// Row delimiter.
	//
	// For example, in a CSV format, *'\n'* is the typical row delimiter.
	RecordRowDelimiter *string `json:"recordRowDelimiter" yaml:"recordRowDelimiter"`
}

Provides additional mapping information when the record format uses delimiters, such as CSV.

For example, the following sample records use CSV format, where the records use the *'\n'* as the row delimiter and a comma (",") as the column delimiter:

`"name1", "address1"`

`"name2", "address2"`

TODO: EXAMPLE

type CfnApplication_InputLambdaProcessorProperty 

type CfnApplication_InputLambdaProcessorProperty struct {
	// The ARN of the [AWS Lambda](https://docs.aws.amazon.com/lambda/) function that operates on records in the stream.
	//
	// > To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see [Example ARNs: AWS Lambda](https://docs.aws.amazon.com//general/latest/gr/aws-arns-and-namespaces.html#arn-syntax-lambda)
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
	// The ARN of the IAM role that is used to access the AWS Lambda function.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
}

An object that contains the Amazon Resource Name (ARN) of the [AWS Lambda](https://docs.aws.amazon.com/lambda/) function that is used to preprocess records in the stream, and the ARN of the IAM role that is used to access the AWS Lambda function.

TODO: EXAMPLE

type CfnApplication_InputParallelismProperty 

type CfnApplication_InputParallelismProperty struct {
	// Number of in-application streams to create.
	//
	// For more information, see [Limits](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html) .
	Count *float64 `json:"count" yaml:"count"`
}

Describes the number of in-application streams to create for a given streaming source.

For information about parallelism, see [Configuring Application Input](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html) .

TODO: EXAMPLE

type CfnApplication_InputProcessingConfigurationProperty 

type CfnApplication_InputProcessingConfigurationProperty struct {
	// The [InputLambdaProcessor](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-inputlambdaprocessor.html) that is used to preprocess the records in the stream before being processed by your application code.
	InputLambdaProcessor interface{} `json:"inputLambdaProcessor" yaml:"inputLambdaProcessor"`
}

Provides a description of 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 [AWS Lambda](https://docs.aws.amazon.com/lambda/) .

TODO: EXAMPLE

type CfnApplication_InputProperty 

type CfnApplication_InputProperty struct {
	// 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.
	//
	// Also used to describe the format of the reference data source.
	InputSchema interface{} `json:"inputSchema" yaml:"inputSchema"`
	// Name prefix to use when creating an in-application stream.
	//
	// Suppose that you specify a prefix "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more (as per the `InputParallelism` count you specified) in-application streams with names "MyInApplicationStream_001," "MyInApplicationStream_002," and so on.
	NamePrefix *string `json:"namePrefix" yaml:"namePrefix"`
	// Describes the number of in-application streams to create.
	//
	// Data from your source is routed to these in-application input streams.
	//
	// See [Configuring Application Input](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html) .
	InputParallelism interface{} `json:"inputParallelism" yaml:"inputParallelism"`
	// The [InputProcessingConfiguration](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-inputprocessingconfiguration.html) 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](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-inputlambdaprocessor.html) .
	InputProcessingConfiguration interface{} `json:"inputProcessingConfiguration" yaml:"inputProcessingConfiguration"`
	// If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
	//
	// Note: Either `KinesisStreamsInput` or `KinesisFirehoseInput` is required.
	KinesisFirehoseInput interface{} `json:"kinesisFirehoseInput" yaml:"kinesisFirehoseInput"`
	// If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
	//
	// Note: Either `KinesisStreamsInput` or `KinesisFirehoseInput` is required.
	KinesisStreamsInput interface{} `json:"kinesisStreamsInput" yaml:"kinesisStreamsInput"`
}

When you configure the application input, you specify the streaming source, the in-application stream name that is created, and the mapping between the two.

For more information, see [Configuring Application Input](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html) .

TODO: EXAMPLE

type CfnApplication_InputSchemaProperty 

type CfnApplication_InputSchemaProperty struct {
	// A list of `RecordColumn` objects.
	RecordColumns interface{} `json:"recordColumns" yaml:"recordColumns"`
	// Specifies the format of the records on the streaming source.
	RecordFormat interface{} `json:"recordFormat" yaml:"recordFormat"`
	// Specifies the encoding of the records in the streaming source.
	//
	// For example, UTF-8.
	RecordEncoding *string `json:"recordEncoding" yaml:"recordEncoding"`
}

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.

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

TODO: EXAMPLE

type CfnApplication_JSONMappingParametersProperty 

type CfnApplication_JSONMappingParametersProperty struct {
	// Path to the top-level parent that contains the records.
	RecordRowPath *string `json:"recordRowPath" yaml:"recordRowPath"`
}

Provides additional mapping information when JSON is the record format on the streaming source.

TODO: EXAMPLE

type CfnApplication_KinesisFirehoseInputProperty 

type CfnApplication_KinesisFirehoseInputProperty struct {
	// ARN of the input delivery stream.
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
	// ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf.
	//
	// You need to make sure that the role has the necessary permissions to access the stream.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
}

Identifies an Amazon Kinesis Firehose delivery stream as the streaming source.

You provide the delivery stream's Amazon Resource Name (ARN) and an IAM role ARN that enables Amazon Kinesis Analytics to access the stream on your behalf.

TODO: EXAMPLE

type CfnApplication_KinesisStreamsInputProperty 

type CfnApplication_KinesisStreamsInputProperty struct {
	// ARN of the input Amazon Kinesis stream to read.
	ResourceArn *string `json:"resourceArn" yaml:"resourceArn"`
	// ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf.
	//
	// You need to grant the necessary permissions to this role.
	RoleArn *string `json:"roleArn" yaml:"roleArn"`
}

Identifies an Amazon Kinesis stream as the streaming source.

You provide the stream's Amazon Resource Name (ARN) and an IAM role ARN that enables Amazon Kinesis Analytics to access the stream on your behalf.

TODO: EXAMPLE

type CfnApplication_MappingParametersProperty 

type CfnApplication_MappingParametersProperty struct {
	// Provides additional mapping information when the record format uses delimiters (for example, CSV).
	CsvMappingParameters interface{} `json:"csvMappingParameters" yaml:"csvMappingParameters"`
	// Provides additional mapping information when JSON is the record format on the streaming source.
	JsonMappingParameters interface{} `json:"jsonMappingParameters" yaml:"jsonMappingParameters"`
}

When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.

TODO: EXAMPLE

type CfnApplication_RecordColumnProperty 

type CfnApplication_RecordColumnProperty struct {
	// Name of the column created in the in-application input stream or reference table.
	Name *string `json:"name" yaml:"name"`
	// Type of column created in the in-application input stream or reference table.
	SqlType *string `json:"sqlType" yaml:"sqlType"`
	// Reference to the data element in the streaming input or the reference data source.
	//
	// This element is required if the [RecordFormatType](https://docs.aws.amazon.com/kinesisanalytics/latest/dev/API_RecordFormat.html#analytics-Type-RecordFormat-RecordFormatTypel) is `JSON` .
	Mapping *string `json:"mapping" yaml:"mapping"`
}

Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

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

TODO: EXAMPLE

type CfnApplication_RecordFormatProperty 

type CfnApplication_RecordFormatProperty struct {
	// The type of record format.
	RecordFormatType *string `json:"recordFormatType" yaml:"recordFormatType"`
	// When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
	MappingParameters interface{} `json:"mappingParameters" yaml:"mappingParameters"`
}

Describes the record format and relevant mapping information that should be applied to schematize the records on the stream.

TODO: EXAMPLE

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.