Values (p.awso.0.9.1.doc.awso.kinesisanalyticsv2.Awso

Sourceval service : Awso.Service.t

Sourceval apiVersion : string

Sourceval endpointPrefix : string

Sourceval serviceFullName : string

Sourceval signatureVersion : string

Sourceval protocol : string

Sourceval globalEndpoint : string

Sourceval serviceAbbreviation : string

Sourceval targetPrefix : string

Sourceval simple_to_json : ('a -> Awso__Botodata.value) -> 'a -> Yojson.Safe.t

Sourceval composed_to_json : ('a -> Awso__Botodata.value) -> 'a -> Yojson.Safe.t

Sourceval to_query : ('a -> Awso.Client.Query.value) -> 'a -> Awso.Client.Query.t

Source

val structure_to_value_aux : 
  ('a * 'b option) list ->
  f:(('a * 'b) list -> 'c) ->
  [> `Structure of 'c ]

Source

val structure_to_value : 
  ('a * 'b option) list ->
  [> `Structure of ('a * 'b) list ]

Source

val structure_to_wrapped_value : 
  wrapper:'a ->
  response:'a ->
  ('b * 'c option) list ->
  [> `Structure of ('a * [> `Structure of ('b * 'c) list ]) list ]

Sourcemodule RecordColumnDelimiter : sig ... end

Sourcemodule RecordRowDelimiter : sig ... end

Sourcemodule RecordRowPath : sig ... end

Sourcemodule RecordColumnMapping : sig ... end

Sourcemodule RecordColumnName : sig ... end

Sourcemodule RecordColumnSqlType : sig ... end

Sourcemodule CSVMappingParameters : sig ... end

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"

Sourcemodule JSONMappingParameters : sig ... end

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

Sourcemodule ResourceARN : sig ... end

Sourcemodule RoleARN : sig ... end

Sourcemodule RecordColumn : sig ... end

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.

Sourcemodule MappingParameters : sig ... end

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.

Sourcemodule RecordFormatType : sig ... end

Sourcemodule PropertyKey : sig ... end

Sourcemodule PropertyValue : sig ... end

Sourcemodule InAppStreamName : sig ... end

Sourcemodule InputParallelismCount : sig ... end

Sourcemodule InputLambdaProcessorDescription : sig ... end

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

Sourcemodule InputStartingPosition : sig ... end

Sourcemodule RecordColumns : sig ... end

Sourcemodule RecordEncoding : sig ... end

Sourcemodule RecordFormat : sig ... end

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.

Sourcemodule BucketARN : sig ... end

Sourcemodule FileKey : sig ... end

Sourcemodule MavenArtifactId : sig ... end

Sourcemodule MavenGroupId : sig ... end

Sourcemodule MavenVersion : sig ... end

Sourcemodule ObjectVersion : sig ... end

Sourcemodule Id : sig ... end

Sourcemodule PropertyMap : sig ... end

Sourcemodule InAppStreamNames : sig ... end

Sourcemodule InputParallelism : sig ... end

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

Sourcemodule InputProcessingConfigurationDescription : sig ... end

For a SQL-based Kinesis Data Analytics application, provides the configuration information about an input processor. Currently, the only input processor available is Amazon Lambda.

Sourcemodule InputStartingPositionConfiguration : sig ... end

Describes the point at which the application reads from the streaming source.

Sourcemodule KinesisFirehoseInputDescription : sig ... end

Describes the Amazon Kinesis Data Firehose delivery stream that is configured as the streaming source in the application input configuration.

Sourcemodule KinesisStreamsInputDescription : sig ... end

For a SQL-based Kinesis Data Analytics application, describes the Kinesis data stream that is configured as the streaming source in the application input configuration.

Sourcemodule SourceSchema : sig ... end

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.

Sourcemodule DestinationSchema : sig ... end

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

Sourcemodule KinesisFirehoseOutputDescription : sig ... end

For a SQL-based Kinesis Data Analytics application's output, describes the Kinesis Data Firehose delivery stream that is configured as its destination.

Sourcemodule KinesisStreamsOutputDescription : sig ... end

For an SQL-based Kinesis Data Analytics application's output, describes the Kinesis data stream that is configured as its destination.

Sourcemodule LambdaOutputDescription : sig ... end

For a SQL-based Kinesis Data Analytics application's output, describes the Amazon Lambda function that is configured as its destination.

Sourcemodule InAppTableName : sig ... end

Sourcemodule S3ReferenceDataSourceDescription : sig ... end

For a SQL-based Kinesis Data Analytics application, provides the bucket name and object key name that stores the reference data.

Sourcemodule SecurityGroupId : sig ... end

Sourcemodule SubnetId : sig ... end

Sourcemodule DatabaseARN : sig ... end

Sourcemodule ArtifactType : sig ... end

Sourcemodule MavenReference : sig ... end

The information required to specify a Maven reference. You can use Maven references to specify dependency JAR files.

Sourcemodule S3ContentLocation : sig ... end

For a Managed Service for Apache Flink application provides a description of an Amazon S3 object, 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.

Sourcemodule BasePath : sig ... end

Sourcemodule InputLambdaProcessorUpdate : sig ... end

For a SQL-based Kinesis Data Analytics application, represents an update to the InputLambdaProcessor that is used to preprocess the records in the stream.

Sourcemodule InputLambdaProcessor : sig ... end

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.

Sourcemodule CodeMD5 : sig ... end

Sourcemodule CodeSize : sig ... end

Sourcemodule S3ApplicationCodeLocationDescription : sig ... end

Describes the location of an application's code stored in an S3 bucket.

Sourcemodule TextContent : sig ... end

Sourcemodule PropertyGroup : sig ... end

Property key-value pairs passed into an application.

Sourcemodule BooleanObject : sig ... end

Sourcemodule CheckpointInterval : sig ... end

Sourcemodule ConfigurationType : sig ... end

Sourcemodule MinPauseBetweenCheckpoints : sig ... end

Sourcemodule LogLevel : sig ... end

Sourcemodule MetricsLevel : sig ... end

Sourcemodule Parallelism : sig ... end

Sourcemodule ParallelismPerKPU : sig ... end

Sourcemodule ApplicationRestoreType : sig ... end

Sourcemodule SnapshotName : sig ... end

Sourcemodule InputDescription : sig ... end

Describes the application input configuration for a SQL-based Kinesis Data Analytics application.

Sourcemodule OutputDescription : sig ... end

For a SQL-based Kinesis Data Analytics application, describes the application output configuration, which includes the in-application stream name and the destination where the stream data is written. The destination can be a Kinesis data stream or a Kinesis Data Firehose delivery stream.

Sourcemodule ReferenceDataSourceDescription : sig ... end

For a SQL-based Kinesis Data Analytics application, describes the reference data source configured for an application.

Sourcemodule SecurityGroupIds : sig ... end

Sourcemodule SubnetIds : sig ... end

Sourcemodule VpcId : sig ... end

Sourcemodule GlueDataCatalogConfigurationDescription : sig ... end

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.

Sourcemodule CustomArtifactConfigurationDescription : sig ... end

Specifies a dependency JAR or a JAR of user-defined functions.

Sourcemodule S3ContentBaseLocationDescription : sig ... end

The description of the S3 base location that holds the application.

Sourcemodule InputParallelismUpdate : sig ... end

For a SQL-based Kinesis Data Analytics application, provides updates to the parallelism count.

Sourcemodule InputProcessingConfigurationUpdate : sig ... end

For a SQL-based Kinesis Data Analytics application, describes updates to an InputProcessingConfiguration.

Sourcemodule InputSchemaUpdate : sig ... end

Describes updates for an SQL-based Kinesis Data Analytics application's input schema.

Sourcemodule KinesisFirehoseInputUpdate : sig ... end

For a SQL-based Kinesis Data Analytics application, when updating application input configuration, provides information about a Kinesis Data Firehose delivery stream as the streaming source.

Sourcemodule KinesisStreamsInputUpdate : sig ... end

When you update the input configuration for a SQL-based Kinesis Data Analytics application, provides information about a Kinesis stream as the streaming source.

Sourcemodule KinesisFirehoseOutputUpdate : sig ... end

For a SQL-based Kinesis Data Analytics application, when updating an output configuration using the UpdateApplication operation, provides information about a Kinesis Data Firehose delivery stream that is configured as the destination.

Sourcemodule KinesisStreamsOutputUpdate : sig ... end

When you update a SQL-based Kinesis Data Analytics application's output configuration using the UpdateApplication operation, provides information about a Kinesis data stream that is configured as the destination.

Sourcemodule LambdaOutputUpdate : sig ... end

When you update an SQL-based Kinesis Data Analytics application's output configuration using the UpdateApplication operation, provides information about an Amazon Lambda function that is configured as the destination.

Sourcemodule S3ReferenceDataSourceUpdate : sig ... end

For a SQL-based Kinesis Data Analytics application, describes the Amazon S3 bucket name and object key name for an in-application reference table.

Sourcemodule InputProcessingConfiguration : sig ... end

For a SQL-based 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.

Sourcemodule KinesisFirehoseInput : sig ... end

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).

Sourcemodule KinesisStreamsInput : sig ... end

Identifies a Kinesis data stream as the streaming source. You provide the stream's Amazon Resource Name (ARN).

Sourcemodule KinesisFirehoseOutput : sig ... end

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.

Sourcemodule KinesisStreamsOutput : sig ... end

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).

Sourcemodule LambdaOutput : sig ... end

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.

Sourcemodule S3ReferenceDataSource : sig ... end

For a SQL-based Kinesis Data Analytics application, identifies the Amazon S3 bucket and object that contains the reference data. A SQL-based Kinesis Data Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.

Sourcemodule CodeContentDescription : sig ... end

Describes details about the code of a Managed Service for Apache Flink application.

Sourcemodule CodeContentType : sig ... end

Sourcemodule KeyId : sig ... end

Sourcemodule KeyType : sig ... end

Sourcemodule PropertyGroups : sig ... end

Sourcemodule CheckpointConfigurationDescription : sig ... end

Describes checkpointing parameters for a Managed Service for Apache Flink application.

Sourcemodule JobPlanDescription : sig ... end

Sourcemodule MonitoringConfigurationDescription : sig ... end

Describes configuration parameters for CloudWatch logging for an application.

Sourcemodule ParallelismConfigurationDescription : sig ... end

Describes parameters for how a Managed Service for Apache Flink application executes multiple tasks simultaneously.

Sourcemodule ApplicationRestoreConfiguration : sig ... end

Specifies the method and snapshot to use when restarting an application using previously saved application state.

Sourcemodule FlinkRunConfiguration : sig ... end

Describes the starting parameters for a Managed Service for Apache Flink application.

Sourcemodule InputDescriptions : sig ... end

Sourcemodule OutputDescriptions : sig ... end

Sourcemodule ReferenceDataSourceDescriptions : sig ... end

Sourcemodule VpcConfigurationDescription : sig ... end

Describes the parameters of a VPC used by the application.

Sourcemodule CatalogConfigurationDescription : sig ... end

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 Managed Service for Apache Flink Studio notebook.

Sourcemodule CustomArtifactsConfigurationDescriptionList : sig ... end

Sourcemodule DeployAsApplicationConfigurationDescription : sig ... end

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

Sourcemodule ZeppelinMonitoringConfigurationDescription : sig ... end

The monitoring configuration for Apache Zeppelin within a Managed Service for Apache Flink Studio notebook.

Sourcemodule LogStreamARN : sig ... end

Sourcemodule S3ContentLocationUpdate : sig ... end

Describes an update for the Amazon S3 code content location for an application.

Sourcemodule ZipFileContent : sig ... end

Sourcemodule InputUpdate : sig ... end

For a SQL-based Kinesis Data Analytics application, describes updates to a specific input configuration (identified by the InputId of an application).

Sourcemodule OutputUpdate : sig ... end

For a SQL-based Kinesis Data Analytics application, describes updates to the output configuration identified by the OutputId.

Sourcemodule ReferenceDataSourceUpdate : sig ... end

When you update a reference data source configuration for a SQL-based Kinesis Data Analytics application, this object provides all the updated values (such as the source bucket name and object key name), the in-application table name that is created, and updated mapping information that maps the data in the Amazon S3 object to the in-application reference table that is created.

Sourcemodule GlueDataCatalogConfigurationUpdate : sig ... end

Updates to the configuration of the Glue Data Catalog that you use for SQL queries that you write in a Managed Service for Apache Flink Studio notebook.

Sourcemodule CustomArtifactConfiguration : sig ... end

Specifies dependency JARs, as well as JAR files that contain user-defined functions (UDF).

Sourcemodule S3ContentBaseLocationUpdate : sig ... end

The information required to update the S3 base location that holds the application.

Sourcemodule ErrorString : sig ... end

An error message that is returned when an operation fails.

Sourcemodule Input : sig ... end

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.

Sourcemodule Output : sig ... end

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.

Sourcemodule ReferenceDataSource : sig ... end

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.

Sourcemodule GlueDataCatalogConfiguration : sig ... end

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.

Sourcemodule S3ContentBaseLocation : sig ... end

The S3 bucket that holds the application information.

Sourcemodule ApplicationCodeConfigurationDescription : sig ... end

Describes code configuration for an application.

Sourcemodule ApplicationEncryptionConfigurationDescription : sig ... end

Describes the encryption at rest configuration.

Sourcemodule ApplicationSnapshotConfigurationDescription : sig ... end

Describes whether snapshots are enabled for a Managed Service for Apache Flink application.

Sourcemodule ApplicationSystemRollbackConfigurationDescription : sig ... end

Describes the system rollback configuration for a Managed Service for Apache Flink application.

Sourcemodule EnvironmentPropertyDescriptions : sig ... end

Describes the execution properties for an Apache Flink runtime.

Sourcemodule FlinkApplicationConfigurationDescription : sig ... end

Describes configuration parameters for a Managed Service for Apache Flink application.

Sourcemodule RunConfigurationDescription : sig ... end

Describes the starting properties for a Managed Service for Apache Flink application.

Sourcemodule SqlApplicationConfigurationDescription : sig ... end

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

Sourcemodule VpcConfigurationDescriptions : sig ... end

Sourcemodule ZeppelinApplicationConfigurationDescription : sig ... end

The configuration of a Managed Service for Apache Flink Studio notebook.

Sourcemodule ApplicationMaintenanceWindowEndTime : sig ... end

Sourcemodule ApplicationMaintenanceWindowStartTime : sig ... end

Sourcemodule CloudWatchLoggingOptionDescription : sig ... end

Describes the Amazon CloudWatch logging option.

Sourcemodule CodeContentUpdate : sig ... end

Describes an update to the code of an application. Not supported for Apache Zeppelin.

Sourcemodule CheckpointConfigurationUpdate : sig ... end

Describes updates to the checkpointing parameters for a Managed Service for Apache Flink application.

Sourcemodule MonitoringConfigurationUpdate : sig ... end

Describes updates to configuration parameters for Amazon CloudWatch logging for an application.

Sourcemodule ParallelismConfigurationUpdate : sig ... end

Describes updates to parameters for how an application executes multiple tasks simultaneously.

Sourcemodule InputUpdates : sig ... end

Sourcemodule OutputUpdates : sig ... end

Sourcemodule ReferenceDataSourceUpdates : sig ... end

Sourcemodule VpcConfigurationUpdate : sig ... end

Describes updates to the VPC configuration used by the application.

Sourcemodule CatalogConfigurationUpdate : sig ... end

Updates to the configuration parameters for the default Amazon Glue database. You use this database for SQL queries that you write in a Managed Service for Apache Flink Studio notebook.

Sourcemodule CustomArtifactsConfigurationList : sig ... end

Sourcemodule DeployAsApplicationConfigurationUpdate : sig ... end

Updates to the configuration information required to deploy an Amazon Data Analytics Studio notebook as an application with durable state.

Sourcemodule ZeppelinMonitoringConfigurationUpdate : sig ... end

Updates to the monitoring configuration for Apache Zeppelin within a Managed Service for Apache Flink Studio notebook.

Sourcemodule TagKey : sig ... end

Sourcemodule TagValue : sig ... end

Sourcemodule SqlRunConfiguration : sig ... end

Describes the starting parameters for a SQL-based Kinesis Data Analytics application.

Sourcemodule ApplicationMode : sig ... end

Sourcemodule ApplicationName : sig ... end

The name of the application.

Sourcemodule ApplicationStatus : sig ... end

Sourcemodule ApplicationVersionId : sig ... end

Sourcemodule RuntimeEnvironment : sig ... end

Sourcemodule SnapshotStatus : sig ... end

Sourcemodule Timestamp : sig ... end

Sourcemodule Operation : sig ... end

The type of operation that is performed on an application.

Sourcemodule OperationId : sig ... end

The operation ID of the request.

Sourcemodule OperationStatus : sig ... end

Sourcemodule ParsedInputRecordField : sig ... end

Sourcemodule ProcessedInputRecord : sig ... end

Sourcemodule RawInputRecord : sig ... end

Sourcemodule ErrorInfo : sig ... end

A description of the error that caused an operation to fail.

Sourcemodule CodeContent : sig ... end

Specifies either the application code, or the location of the application code, for a Managed Service for Apache Flink application.

Sourcemodule CheckpointConfiguration : sig ... end

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 in the Apache Flink Documentation.

Sourcemodule MonitoringConfiguration : sig ... end

Describes configuration parameters for Amazon CloudWatch logging for an application. For more information about CloudWatch logging, see Monitoring.

Sourcemodule ParallelismConfiguration : sig ... end

Describes parameters for how a Managed Service for Apache Flink application executes multiple tasks simultaneously. For more information about parallelism, see Parallel Execution in the Apache Flink Documentation.

Sourcemodule Inputs : sig ... end

Sourcemodule Outputs : sig ... end

Sourcemodule ReferenceDataSources : sig ... end

Sourcemodule VpcConfiguration : sig ... end

Describes the parameters of a VPC used by the application.

Sourcemodule CatalogConfiguration : sig ... end

The configuration parameters for the default Amazon Glue database. You use this database for SQL queries that you write in a Managed Service for Apache Flink Studio notebook.

Sourcemodule DeployAsApplicationConfiguration : sig ... end

The information required to deploy a Managed Service for Apache Flink Studio notebook as an application with durable state.

Sourcemodule ZeppelinMonitoringConfiguration : sig ... end

Describes configuration parameters for Amazon CloudWatch logging for a Managed Service for Apache Flink Studio notebook. For more information about CloudWatch logging, see Monitoring.

Sourcemodule ApplicationConfigurationDescription : sig ... end

Describes details about the application code and starting parameters for a Managed Service for Apache Flink application.

Sourcemodule ApplicationDescription : sig ... end

Sourcemodule ApplicationMaintenanceConfigurationDescription : sig ... end

The details of the maintenance configuration for the application.

Sourcemodule CloudWatchLoggingOptionDescriptions : sig ... end

Sourcemodule ConditionalToken : sig ... end

Sourcemodule ErrorMessage : sig ... end

Sourcemodule ApplicationCodeConfigurationUpdate : sig ... end

Describes code configuration updates for an application. This is supported for a Managed Service for Apache Flink application or a SQL-based Kinesis Data Analytics application.

Sourcemodule ApplicationEncryptionConfigurationUpdate : sig ... end

Describes configuration updates to encryption at rest.

Sourcemodule ApplicationSnapshotConfigurationUpdate : sig ... end

Describes updates to whether snapshots are enabled for a Managed Service for Apache Flink application.

Sourcemodule ApplicationSystemRollbackConfigurationUpdate : sig ... end

Describes the system rollback configuration for a Managed Service for Apache Flink application.

Sourcemodule EnvironmentPropertyUpdates : sig ... end

Describes updates to the execution property groups for a Managed Service for Apache Flink application or a Studio notebook.

Sourcemodule FlinkApplicationConfigurationUpdate : sig ... end

Describes updates to the configuration parameters for a Managed Service for Apache Flink application.

Sourcemodule SqlApplicationConfigurationUpdate : sig ... end

Describes updates to the input streams, destination streams, and reference data sources for a SQL-based Kinesis Data Analytics application.

Sourcemodule VpcConfigurationUpdates : sig ... end

Sourcemodule ZeppelinApplicationConfigurationUpdate : sig ... end

Updates to the configuration of Managed Service for Apache Flink Studio notebook.

Sourcemodule CloudWatchLoggingOptionUpdate : sig ... end

Describes the Amazon CloudWatch logging option updates.

Sourcemodule Tag : sig ... end

A key-value pair (the value is optional) that you can define and assign to Amazon resources. If you specify a tag that already exists, the tag value is replaced with the value that you specify in the request. Note that the maximum number of application tags includes system tags. The maximum number of user-defined application tags is 50. For more information, see Using Tagging.

Sourcemodule SqlRunConfigurations : sig ... end

Sourcemodule ApplicationSummary : sig ... end

Provides application summary information, including the application Amazon Resource Name (ARN), name, and status.

Sourcemodule ApplicationVersionSummary : sig ... end

The summary of the application version.

Sourcemodule SnapshotDetails : sig ... end

Provides details about a snapshot of application state.

Sourcemodule ApplicationOperationInfo : sig ... end

A description of the aplication operation that provides information about the updates that were made to the application.

Sourcemodule ParsedInputRecord : sig ... end

Sourcemodule ProcessedInputRecords : sig ... end

Sourcemodule RawInputRecords : sig ... end

Sourcemodule ApplicationVersionChangeDetails : sig ... end

Contains information about the version changes that the operation applied to the application.

Sourcemodule OperationFailureDetails : sig ... end

Provides a description of the operation failure.

Sourcemodule ApplicationCodeConfiguration : sig ... end

Describes code configuration for an application.

Sourcemodule ApplicationEncryptionConfiguration : sig ... end

Specifies the configuration to manage encryption at rest.

Sourcemodule ApplicationSnapshotConfiguration : sig ... end

Describes whether snapshots are enabled for a Managed Service for Apache Flink application.

Sourcemodule ApplicationSystemRollbackConfiguration : sig ... end

Describes the system rollback configuration for a Managed Service for Apache Flink application.

Sourcemodule EnvironmentProperties : sig ... end

Describes execution properties for a Managed Service for Apache Flink application.

Sourcemodule FlinkApplicationConfiguration : sig ... end

Describes configuration parameters for a Managed Service for Apache Flink application or a Studio notebook.

Sourcemodule SqlApplicationConfiguration : sig ... end

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

Sourcemodule VpcConfigurations : sig ... end

Sourcemodule ZeppelinApplicationConfiguration : sig ... end

The configuration of a Managed Service for Apache Flink Studio notebook.

Sourcemodule CloudWatchLoggingOption : sig ... end

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

Sourcemodule ApplicationDetail : sig ... end

Describes the application, including the application Amazon Resource Name (ARN), status, latest version, and input and output configurations.

Sourcemodule CodeValidationException : sig ... end

The user-provided application code (query) is not valid. This can be a simple syntax error.

Sourcemodule ConcurrentModificationException : sig ... end

Exception thrown as a result of concurrent modifications to an application. This error can be the result of attempting to modify an application without using the current application ID.

Sourcemodule InvalidApplicationConfigurationException : sig ... end

The user-provided application configuration is not valid.

Sourcemodule InvalidArgumentException : sig ... end

The specified input parameter value is not valid.

Sourcemodule InvalidRequestException : sig ... end

The request JSON is not valid for the operation.

Sourcemodule LimitExceededException : sig ... end

The number of allowed resources has been exceeded.

Sourcemodule ResourceInUseException : sig ... end

The application is not available for this operation.

Sourcemodule ResourceNotFoundException : sig ... end

Specified application can't be found.

Sourcemodule ApplicationConfigurationUpdate : sig ... end

Describes updates to an application's configuration.

Sourcemodule CloudWatchLoggingOptionUpdates : sig ... end

Sourcemodule RunConfigurationUpdate : sig ... end

Describes the updates to the starting parameters for a Managed Service for Apache Flink application.

Sourcemodule UnsupportedOperationException : sig ... end

The request was rejected because a specified parameter is not supported or a specified resource is not valid for this operation.

Sourcemodule ApplicationMaintenanceConfigurationUpdate : sig ... end

Describes the updated maintenance configuration for the application.

Sourcemodule TooManyTagsException : sig ... end

Application created with too many tags, or too many tags added to an application. Note that the maximum number of application tags includes system tags. The maximum number of user-defined application tags is 50.

Sourcemodule KinesisAnalyticsARN : sig ... end

Sourcemodule TagKeys : sig ... end

Sourcemodule Tags : sig ... end

Sourcemodule RunConfiguration : sig ... end

Describes the starting parameters for an Managed Service for Apache Flink application.

Sourcemodule ApplicationSummaries : sig ... end

Sourcemodule ListApplicationsInputLimit : sig ... end

Sourcemodule ApplicationVersionSummaries : sig ... end

Sourcemodule NextToken : sig ... end

A pagination token that can be used in a subsequent request.

Sourcemodule ListApplicationVersionsInputLimit : sig ... end

Sourcemodule SnapshotSummaries : sig ... end

Sourcemodule ListSnapshotsInputLimit : sig ... end

Sourcemodule ApplicationOperationInfoList : sig ... end

Sourcemodule ListApplicationOperationsInputLimit : sig ... end

The limit on the number of records to be returned in the response.

Sourcemodule ParsedInputRecords : sig ... end

Sourcemodule ResourceProvisionedThroughputExceededException : sig ... end

Discovery failed to get a record from the streaming source because of the Kinesis Streams ProvisionedThroughputExceededException. For more information, see GetRecords in the Amazon Kinesis Streams API Reference.

Sourcemodule ServiceUnavailableException : sig ... end

The service cannot complete the request.

Sourcemodule UnableToDetectSchemaException : sig ... end

The data format is not valid. Kinesis Data Analytics cannot detect the schema for the given streaming source.

Sourcemodule S3Configuration : sig ... end

For a SQL-based Kinesis Data Analytics application, provides a description of an Amazon S3 data source, including the Amazon Resource Name (ARN) of the S3 bucket and the name of the Amazon S3 object that contains the data.

Sourcemodule ApplicationOperationInfoDetails : sig ... end

A description of the application operation that provides information about the updates that were made to the application.

Sourcemodule ApplicationConfiguration : sig ... end

Specifies the creation parameters for a Managed Service for Apache Flink application.

Sourcemodule CloudWatchLoggingOptions : sig ... end

Sourcemodule AuthorizedUrl : sig ... end

Sourcemodule SessionExpirationDurationInSeconds : sig ... end

Sourcemodule UrlType : sig ... end

Sourcemodule UpdateApplicationResponse : sig ... end

Updates an existing Managed Service for Apache Flink application. Using this operation, you can update application code, input configuration, and output configuration. Managed Service for Apache Flink updates the ApplicationVersionId each time you update your application.

Sourcemodule UpdateApplicationRequest : sig ... end

Updates an existing Managed Service for Apache Flink application. Using this operation, you can update application code, input configuration, and output configuration. Managed Service for Apache Flink updates the ApplicationVersionId each time you update your application.

Sourcemodule UpdateApplicationMaintenanceConfigurationResponse : sig ... end

Updates the maintenance configuration of the Managed Service for Apache Flink application. You can invoke this operation on an application that is in one of the two following states: READY or RUNNING. If you invoke it when the application is in a state other than these two states, it throws a ResourceInUseException. The service makes use of the updated configuration the next time it schedules maintenance for the application. If you invoke this operation after the service schedules maintenance, the service will apply the configuration update the next time it schedules maintenance for the application. This means that you might not see the maintenance configuration update applied to the maintenance process that follows a successful invocation of this operation, but to the following maintenance process instead. To see the current maintenance configuration of your application, invoke the DescribeApplication operation. For information about application maintenance, see Managed Service for Apache Flink for Apache Flink Maintenance. This operation is supported only for Managed Service for Apache Flink.

Sourcemodule UpdateApplicationMaintenanceConfigurationRequest : sig ... end

Updates the maintenance configuration of the Managed Service for Apache Flink application. You can invoke this operation on an application that is in one of the two following states: READY or RUNNING. If you invoke it when the application is in a state other than these two states, it throws a ResourceInUseException. The service makes use of the updated configuration the next time it schedules maintenance for the application. If you invoke this operation after the service schedules maintenance, the service will apply the configuration update the next time it schedules maintenance for the application. This means that you might not see the maintenance configuration update applied to the maintenance process that follows a successful invocation of this operation, but to the following maintenance process instead. To see the current maintenance configuration of your application, invoke the DescribeApplication operation. For information about application maintenance, see Managed Service for Apache Flink for Apache Flink Maintenance. This operation is supported only for Managed Service for Apache Flink.

Sourcemodule UntagResourceResponse : sig ... end

Removes one or more tags from a Managed Service for Apache Flink application. For more information, see Using Tagging.

Sourcemodule UntagResourceRequest : sig ... end

Removes one or more tags from a Managed Service for Apache Flink application. For more information, see Using Tagging.

Sourcemodule TagResourceResponse : sig ... end

Adds one or more key-value tags to a Managed Service for Apache Flink application. Note that the maximum number of application tags includes system tags. The maximum number of user-defined application tags is 50. For more information, see Using Tagging.

Sourcemodule TagResourceRequest : sig ... end

Adds one or more key-value tags to a Managed Service for Apache Flink application. Note that the maximum number of application tags includes system tags. The maximum number of user-defined application tags is 50. For more information, see Using Tagging.

Sourcemodule StopApplicationResponse : sig ... end

Stops the application from processing data. You can stop an application only if it is in the running status, unless you set the Force parameter to true. You can use the DescribeApplication operation to find the application status. Managed Service for Apache Flink takes a snapshot when the application is stopped, unless Force is set to true.

Sourcemodule StopApplicationRequest : sig ... end

Stops the application from processing data. You can stop an application only if it is in the running status, unless you set the Force parameter to true. You can use the DescribeApplication operation to find the application status. Managed Service for Apache Flink takes a snapshot when the application is stopped, unless Force is set to true.

Sourcemodule StartApplicationResponse : sig ... end

Starts the specified Managed Service for Apache Flink application. After creating an application, you must exclusively call this operation to start your application.

Sourcemodule StartApplicationRequest : sig ... end

Starts the specified Managed Service for Apache Flink application. After creating an application, you must exclusively call this operation to start your application.

Sourcemodule RollbackApplicationResponse : sig ... end

Reverts the application to the previous running version. You can roll back an application if you suspect it is stuck in a transient status or in the running status. You can roll back an application only if it is in the UPDATING, AUTOSCALING, or RUNNING statuses. When you rollback an application, it loads state data from the last successful snapshot. If the application has no snapshots, Managed Service for Apache Flink rejects the rollback request.

Sourcemodule RollbackApplicationRequest : sig ... end

Reverts the application to the previous running version. You can roll back an application if you suspect it is stuck in a transient status or in the running status. You can roll back an application only if it is in the UPDATING, AUTOSCALING, or RUNNING statuses. When you rollback an application, it loads state data from the last successful snapshot. If the application has no snapshots, Managed Service for Apache Flink rejects the rollback request.

Sourcemodule ListTagsForResourceResponse : sig ... end

Retrieves the list of key-value tags assigned to the application. For more information, see Using Tagging.

Sourcemodule ListTagsForResourceRequest : sig ... end

Retrieves the list of key-value tags assigned to the application. For more information, see Using Tagging.

Sourcemodule ListApplicationsResponse : sig ... end

Returns a list of Managed Service for Apache Flink applications in your account. For each application, the response includes the application name, Amazon Resource Name (ARN), and status. If you want detailed information about a specific application, use DescribeApplication.

Sourcemodule ListApplicationsRequest : sig ... end

Returns a list of Managed Service for Apache Flink applications in your account. For each application, the response includes the application name, Amazon Resource Name (ARN), and status. If you want detailed information about a specific application, use DescribeApplication.

Sourcemodule ListApplicationVersionsResponse : sig ... end

Lists all the versions for the specified application, including versions that were rolled back. The response also includes a summary of the configuration associated with each version. To get the complete description of a specific application version, invoke the DescribeApplicationVersion operation. This operation is supported only for Managed Service for Apache Flink.

Sourcemodule ListApplicationVersionsRequest : sig ... end

Lists all the versions for the specified application, including versions that were rolled back. The response also includes a summary of the configuration associated with each version. To get the complete description of a specific application version, invoke the DescribeApplicationVersion operation. This operation is supported only for Managed Service for Apache Flink.

Sourcemodule ListApplicationSnapshotsResponse : sig ... end

Lists information about the current application snapshots.

Sourcemodule ListApplicationSnapshotsRequest : sig ... end

Lists information about the current application snapshots.

Sourcemodule ListApplicationOperationsResponse : sig ... end

A response that returns a list of operations for an application.

Sourcemodule ListApplicationOperationsRequest : sig ... end

A request for a list of operations performed on an application.

Sourcemodule DiscoverInputSchemaResponse : sig ... end

Infers a schema for a SQL-based Kinesis Data Analytics application by evaluating sample records on the specified streaming source (Kinesis data stream or Kinesis Data Firehose delivery stream) or Amazon S3 object. In the response, the operation returns the inferred schema and also the sample records that the operation used to infer the schema. You can use the inferred schema when configuring a streaming source for your application. When you create an application using the Kinesis Data Analytics console, the console uses this operation to infer a schema and show it in the console user interface.

Sourcemodule DiscoverInputSchemaRequest : sig ... end

Infers a schema for a SQL-based Kinesis Data Analytics application by evaluating sample records on the specified streaming source (Kinesis data stream or Kinesis Data Firehose delivery stream) or Amazon S3 object. In the response, the operation returns the inferred schema and also the sample records that the operation used to infer the schema. You can use the inferred schema when configuring a streaming source for your application. When you create an application using the Kinesis Data Analytics console, the console uses this operation to infer a schema and show it in the console user interface.

Sourcemodule DescribeApplicationVersionResponse : sig ... end

Provides a detailed description of a specified version of the application. To see a list of all the versions of an application, invoke the ListApplicationVersions operation. This operation is supported only for Managed Service for Apache Flink.

Sourcemodule DescribeApplicationVersionRequest : sig ... end

Provides a detailed description of a specified version of the application. To see a list of all the versions of an application, invoke the ListApplicationVersions operation. This operation is supported only for Managed Service for Apache Flink.

Sourcemodule DescribeApplicationSnapshotResponse : sig ... end

Returns information about a snapshot of application state data.

Sourcemodule DescribeApplicationSnapshotRequest : sig ... end

Returns information about a snapshot of application state data.

Sourcemodule DescribeApplicationResponse : sig ... end

Returns information about a specific Managed Service for Apache Flink application. If you want to retrieve a list of all applications in your account, use the ListApplications operation.

Sourcemodule DescribeApplicationRequest : sig ... end

Returns information about a specific Managed Service for Apache Flink application. If you want to retrieve a list of all applications in your account, use the ListApplications operation.

Sourcemodule DescribeApplicationOperationResponse : sig ... end

Provides details of the operation that corresponds to the operation ID on a Managed Service for Apache Flink application.

Sourcemodule DescribeApplicationOperationRequest : sig ... end

A request for information about a specific operation that was performed on a Managed Service for Apache Flink application.

Sourcemodule DeleteApplicationVpcConfigurationResponse : sig ... end

Removes a VPC configuration from a Managed Service for Apache Flink application.

Sourcemodule DeleteApplicationVpcConfigurationRequest : sig ... end

Removes a VPC configuration from a Managed Service for Apache Flink application.

Sourcemodule DeleteApplicationSnapshotResponse : sig ... end

Deletes a snapshot of application state.

Sourcemodule DeleteApplicationSnapshotRequest : sig ... end

Deletes a snapshot of application state.

Sourcemodule DeleteApplicationResponse : sig ... end

Deletes the specified application. Managed Service for Apache Flink halts application execution and deletes the application.

Sourcemodule DeleteApplicationRequest : sig ... end

Deletes the specified application. Managed Service for Apache Flink halts application execution and deletes the application.

Sourcemodule DeleteApplicationReferenceDataSourceResponse : sig ... end

Deletes a reference data source configuration from the specified SQL-based Kinesis Data Analytics application's configuration. If the application is running, Kinesis Data Analytics immediately removes the in-application table that you created using the AddApplicationReferenceDataSource operation.

Sourcemodule DeleteApplicationReferenceDataSourceRequest : sig ... end

Deletes a reference data source configuration from the specified SQL-based Kinesis Data Analytics application's configuration. If the application is running, Kinesis Data Analytics immediately removes the in-application table that you created using the AddApplicationReferenceDataSource operation.

Sourcemodule DeleteApplicationOutputResponse : sig ... end

Deletes the output destination configuration from your SQL-based Kinesis Data Analytics application's configuration. Kinesis Data Analytics will no longer write data from the corresponding in-application stream to the external output destination.

Sourcemodule DeleteApplicationOutputRequest : sig ... end

Deletes the output destination configuration from your SQL-based Kinesis Data Analytics application's configuration. Kinesis Data Analytics will no longer write data from the corresponding in-application stream to the external output destination.

Sourcemodule DeleteApplicationInputProcessingConfigurationResponse : sig ... end

Deletes an InputProcessingConfiguration from an input.

Sourcemodule DeleteApplicationInputProcessingConfigurationRequest : sig ... end

Deletes an InputProcessingConfiguration from an input.

Sourcemodule DeleteApplicationCloudWatchLoggingOptionResponse : sig ... end

Deletes an Amazon CloudWatch log stream from an SQL-based Kinesis Data Analytics application.

Sourcemodule DeleteApplicationCloudWatchLoggingOptionRequest : sig ... end

Deletes an Amazon CloudWatch log stream from an SQL-based Kinesis Data Analytics application.

Sourcemodule CreateApplicationSnapshotResponse : sig ... end

Creates a snapshot of the application's state data.

Sourcemodule CreateApplicationSnapshotRequest : sig ... end

Creates a snapshot of the application's state data.

Sourcemodule CreateApplicationResponse : sig ... end

Creates a Managed Service for Apache Flink application. For information about creating a Managed Service for Apache Flink application, see Creating an Application.

Sourcemodule CreateApplicationRequest : sig ... end

Creates a Managed Service for Apache Flink application. For information about creating a Managed Service for Apache Flink application, see Creating an Application.

Sourcemodule CreateApplicationPresignedUrlResponse : sig ... end

Creates and returns a URL that you can use to connect to an application's extension. The IAM role or user used to call this API defines the permissions to access the extension. After the presigned URL is created, no additional permission is required to access this URL. IAM authorization policies for this API are also enforced for every HTTP request that attempts to connect to the extension. You control the amount of time that the URL will be valid using the SessionExpirationDurationInSeconds parameter. If you do not provide this parameter, the returned URL is valid for twelve hours. The URL that you get from a call to CreateApplicationPresignedUrl must be used within 3 minutes to be valid. If you first try to use the URL after the 3-minute limit expires, the service returns an HTTP 403 Forbidden error.

Sourcemodule CreateApplicationPresignedUrlRequest : sig ... end

Creates and returns a URL that you can use to connect to an application's extension. The IAM role or user used to call this API defines the permissions to access the extension. After the presigned URL is created, no additional permission is required to access this URL. IAM authorization policies for this API are also enforced for every HTTP request that attempts to connect to the extension. You control the amount of time that the URL will be valid using the SessionExpirationDurationInSeconds parameter. If you do not provide this parameter, the returned URL is valid for twelve hours. The URL that you get from a call to CreateApplicationPresignedUrl must be used within 3 minutes to be valid. If you first try to use the URL after the 3-minute limit expires, the service returns an HTTP 403 Forbidden error.

Sourcemodule AddApplicationVpcConfigurationResponse : sig ... end

Adds a Virtual Private Cloud (VPC) configuration to the application. Applications can use VPCs to store and access resources securely. Note the following about VPC configurations for Managed Service for Apache Flink applications: VPC configurations are not supported for SQL applications. When a VPC is added to a Managed Service for Apache Flink application, the application can no longer be accessed from the Internet directly. To enable Internet access to the application, add an Internet gateway to your VPC.

Sourcemodule AddApplicationVpcConfigurationRequest : sig ... end

Adds a Virtual Private Cloud (VPC) configuration to the application. Applications can use VPCs to store and access resources securely. Note the following about VPC configurations for Managed Service for Apache Flink applications: VPC configurations are not supported for SQL applications. When a VPC is added to a Managed Service for Apache Flink application, the application can no longer be accessed from the Internet directly. To enable Internet access to the application, add an Internet gateway to your VPC.

Sourcemodule AddApplicationReferenceDataSourceResponse : sig ... end

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.

Sourcemodule AddApplicationReferenceDataSourceRequest : sig ... end

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.

Sourcemodule AddApplicationOutputResponse : sig ... end

Adds an external destination to your SQL-based 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 operation to find the current application version.

Sourcemodule AddApplicationOutputRequest : sig ... end

Adds an external destination to your SQL-based 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 operation to find the current application version.

Sourcemodule AddApplicationInputResponse : sig ... end

Adds a streaming source to your SQL-based Kinesis Data Analytics application. You can add a streaming source when you create an application, or you can use this operation to add a streaming source after you create an application. For more information, see CreateApplication. 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.

Sourcemodule AddApplicationInputRequest : sig ... end

Adds a streaming source to your SQL-based Kinesis Data Analytics application. You can add a streaming source when you create an application, or you can use this operation to add a streaming source after you create an application. For more information, see CreateApplication. 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.

Sourcemodule AddApplicationInputProcessingConfigurationResponse : sig ... end

Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics application. An input processor pre-processes records on the input stream before the application's SQL code executes. Currently, the only input processor available is Amazon Lambda.

Sourcemodule AddApplicationInputProcessingConfigurationRequest : sig ... end

Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics application. An input processor pre-processes records on the input stream before the application's SQL code executes. Currently, the only input processor available is Amazon Lambda.

Sourcemodule AddApplicationCloudWatchLoggingOptionResponse : sig ... end

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

Sourcemodule AddApplicationCloudWatchLoggingOptionRequest : sig ... end

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