Awso_kinesisanalyticsv2_eioSourceval add_application_cloud_watch_logging_option :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.AddApplicationCloudWatchLoggingOptionRequest.t ->
(Awso_kinesisanalyticsv2.Values.AddApplicationCloudWatchLoggingOptionResponse.t,
Awso_kinesisanalyticsv2.Values.AddApplicationCloudWatchLoggingOptionResponse.error)
Result.tval add_application_input :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.AddApplicationInputRequest.t ->
(Awso_kinesisanalyticsv2.Values.AddApplicationInputResponse.t,
Awso_kinesisanalyticsv2.Values.AddApplicationInputResponse.error)
Result.tval add_application_input_processing_configuration :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.AddApplicationInputProcessingConfigurationRequest.t ->
(Awso_kinesisanalyticsv2.Values.AddApplicationInputProcessingConfigurationResponse.t,
Awso_kinesisanalyticsv2.Values.AddApplicationInputProcessingConfigurationResponse.error)
Result.tval add_application_output :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.AddApplicationOutputRequest.t ->
(Awso_kinesisanalyticsv2.Values.AddApplicationOutputResponse.t,
Awso_kinesisanalyticsv2.Values.AddApplicationOutputResponse.error)
Result.tval add_application_reference_data_source :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.AddApplicationReferenceDataSourceRequest.t ->
(Awso_kinesisanalyticsv2.Values.AddApplicationReferenceDataSourceResponse.t,
Awso_kinesisanalyticsv2.Values.AddApplicationReferenceDataSourceResponse.error)
Result.tval add_application_vpc_configuration :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.AddApplicationVpcConfigurationRequest.t ->
(Awso_kinesisanalyticsv2.Values.AddApplicationVpcConfigurationResponse.t,
Awso_kinesisanalyticsv2.Values.AddApplicationVpcConfigurationResponse.error)
Result.tval create_application :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.CreateApplicationRequest.t ->
(Awso_kinesisanalyticsv2.Values.CreateApplicationResponse.t,
Awso_kinesisanalyticsv2.Values.CreateApplicationResponse.error)
Result.tval create_application_presigned_url :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.CreateApplicationPresignedUrlRequest.t ->
(Awso_kinesisanalyticsv2.Values.CreateApplicationPresignedUrlResponse.t,
Awso_kinesisanalyticsv2.Values.CreateApplicationPresignedUrlResponse.error)
Result.tval create_application_snapshot :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.CreateApplicationSnapshotRequest.t ->
(Awso_kinesisanalyticsv2.Values.CreateApplicationSnapshotResponse.t,
Awso_kinesisanalyticsv2.Values.CreateApplicationSnapshotResponse.error)
Result.tval delete_application :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DeleteApplicationRequest.t ->
(Awso_kinesisanalyticsv2.Values.DeleteApplicationResponse.t,
Awso_kinesisanalyticsv2.Values.DeleteApplicationResponse.error)
Result.tval delete_application_cloud_watch_logging_option :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DeleteApplicationCloudWatchLoggingOptionRequest.t ->
(Awso_kinesisanalyticsv2.Values.DeleteApplicationCloudWatchLoggingOptionResponse.t,
Awso_kinesisanalyticsv2.Values.DeleteApplicationCloudWatchLoggingOptionResponse.error)
Result.tval delete_application_input_processing_configuration :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DeleteApplicationInputProcessingConfigurationRequest.t ->
(Awso_kinesisanalyticsv2.Values.DeleteApplicationInputProcessingConfigurationResponse.t,
Awso_kinesisanalyticsv2.Values.DeleteApplicationInputProcessingConfigurationResponse.error)
Result.tval delete_application_output :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DeleteApplicationOutputRequest.t ->
(Awso_kinesisanalyticsv2.Values.DeleteApplicationOutputResponse.t,
Awso_kinesisanalyticsv2.Values.DeleteApplicationOutputResponse.error)
Result.tval delete_application_reference_data_source :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DeleteApplicationReferenceDataSourceRequest.t ->
(Awso_kinesisanalyticsv2.Values.DeleteApplicationReferenceDataSourceResponse.t,
Awso_kinesisanalyticsv2.Values.DeleteApplicationReferenceDataSourceResponse.error)
Result.tval delete_application_snapshot :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DeleteApplicationSnapshotRequest.t ->
(Awso_kinesisanalyticsv2.Values.DeleteApplicationSnapshotResponse.t,
Awso_kinesisanalyticsv2.Values.DeleteApplicationSnapshotResponse.error)
Result.tval delete_application_vpc_configuration :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DeleteApplicationVpcConfigurationRequest.t ->
(Awso_kinesisanalyticsv2.Values.DeleteApplicationVpcConfigurationResponse.t,
Awso_kinesisanalyticsv2.Values.DeleteApplicationVpcConfigurationResponse.error)
Result.tval describe_application :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DescribeApplicationRequest.t ->
(Awso_kinesisanalyticsv2.Values.DescribeApplicationResponse.t,
Awso_kinesisanalyticsv2.Values.DescribeApplicationResponse.error)
Result.tval describe_application_operation :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DescribeApplicationOperationRequest.t ->
(Awso_kinesisanalyticsv2.Values.DescribeApplicationOperationResponse.t,
Awso_kinesisanalyticsv2.Values.DescribeApplicationOperationResponse.error)
Result.tval describe_application_snapshot :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DescribeApplicationSnapshotRequest.t ->
(Awso_kinesisanalyticsv2.Values.DescribeApplicationSnapshotResponse.t,
Awso_kinesisanalyticsv2.Values.DescribeApplicationSnapshotResponse.error)
Result.tval describe_application_version :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DescribeApplicationVersionRequest.t ->
(Awso_kinesisanalyticsv2.Values.DescribeApplicationVersionResponse.t,
Awso_kinesisanalyticsv2.Values.DescribeApplicationVersionResponse.error)
Result.tval discover_input_schema :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.DiscoverInputSchemaRequest.t ->
(Awso_kinesisanalyticsv2.Values.DiscoverInputSchemaResponse.t,
Awso_kinesisanalyticsv2.Values.DiscoverInputSchemaResponse.error)
Result.tval list_application_operations :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.ListApplicationOperationsRequest.t ->
(Awso_kinesisanalyticsv2.Values.ListApplicationOperationsResponse.t,
Awso_kinesisanalyticsv2.Values.ListApplicationOperationsResponse.error)
Result.tval list_application_snapshots :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.ListApplicationSnapshotsRequest.t ->
(Awso_kinesisanalyticsv2.Values.ListApplicationSnapshotsResponse.t,
Awso_kinesisanalyticsv2.Values.ListApplicationSnapshotsResponse.error)
Result.tval list_application_versions :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.ListApplicationVersionsRequest.t ->
(Awso_kinesisanalyticsv2.Values.ListApplicationVersionsResponse.t,
Awso_kinesisanalyticsv2.Values.ListApplicationVersionsResponse.error)
Result.tval list_applications :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.ListApplicationsRequest.t ->
(Awso_kinesisanalyticsv2.Values.ListApplicationsResponse.t,
Awso_kinesisanalyticsv2.Values.ListApplicationsResponse.error)
Result.tval list_tags_for_resource :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.ListTagsForResourceRequest.t ->
(Awso_kinesisanalyticsv2.Values.ListTagsForResourceResponse.t,
Awso_kinesisanalyticsv2.Values.ListTagsForResourceResponse.error)
Result.tval rollback_application :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.RollbackApplicationRequest.t ->
(Awso_kinesisanalyticsv2.Values.RollbackApplicationResponse.t,
Awso_kinesisanalyticsv2.Values.RollbackApplicationResponse.error)
Result.tval start_application :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.StartApplicationRequest.t ->
(Awso_kinesisanalyticsv2.Values.StartApplicationResponse.t,
Awso_kinesisanalyticsv2.Values.StartApplicationResponse.error)
Result.tval stop_application :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.StopApplicationRequest.t ->
(Awso_kinesisanalyticsv2.Values.StopApplicationResponse.t,
Awso_kinesisanalyticsv2.Values.StopApplicationResponse.error)
Result.tval tag_resource :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.TagResourceRequest.t ->
(Awso_kinesisanalyticsv2.Values.TagResourceResponse.t,
Awso_kinesisanalyticsv2.Values.TagResourceResponse.error)
Result.tval untag_resource :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.UntagResourceRequest.t ->
(Awso_kinesisanalyticsv2.Values.UntagResourceResponse.t,
Awso_kinesisanalyticsv2.Values.UntagResourceResponse.error)
Result.tval update_application :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.UpdateApplicationRequest.t ->
(Awso_kinesisanalyticsv2.Values.UpdateApplicationResponse.t,
Awso_kinesisanalyticsv2.Values.UpdateApplicationResponse.error)
Result.tval update_application_maintenance_configuration :
?endpoint_url:string ->
?cfg:Awso_eio.Cfg.t ->
Awso_kinesisanalyticsv2.Values.UpdateApplicationMaintenanceConfigurationRequest.t ->
(Awso_kinesisanalyticsv2.Values.UpdateApplicationMaintenanceConfigurationResponse.t,
Awso_kinesisanalyticsv2.Values.UpdateApplicationMaintenanceConfigurationResponse.error)
Result.tinclude module type of struct include Awso_kinesisanalyticsv2.Values endval structure_to_value_aux :
('a * 'b option) list ->
f:(('a * 'b) list -> 'c) ->
[> `Structure of 'c ]val structure_to_wrapped_value :
wrapper:'a ->
response:'a ->
('b * 'c option) list ->
[> `Structure of ('a * [> `Structure of ('b * 'c) list ]) list ]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"
For a SQL-based Kinesis Data Analytics application, provides additional mapping information when JSON is the record format on the streaming source.
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.
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.
module InputLambdaProcessorDescription =
Awso_kinesisanalyticsv2.Values.InputLambdaProcessorDescriptionFor 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.
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.
For a SQL-based Kinesis Data Analytics application, describes the number of in-application streams to create for a given streaming source.
module InputProcessingConfigurationDescription =
Awso_kinesisanalyticsv2.Values.InputProcessingConfigurationDescriptionFor a SQL-based Kinesis Data Analytics application, provides the configuration information about an input processor. Currently, the only input processor available is Amazon Lambda.
module InputStartingPositionConfiguration =
Awso_kinesisanalyticsv2.Values.InputStartingPositionConfigurationDescribes the point at which the application reads from the streaming source.
module KinesisFirehoseInputDescription =
Awso_kinesisanalyticsv2.Values.KinesisFirehoseInputDescriptionDescribes the Amazon Kinesis Data Firehose delivery stream that is configured as the streaming source in the application input configuration.
module KinesisStreamsInputDescription =
Awso_kinesisanalyticsv2.Values.KinesisStreamsInputDescriptionFor a SQL-based Kinesis Data Analytics application, describes the Kinesis data stream that is configured as the streaming source in the application input configuration.
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.
Describes the data format when records are written to the destination in a SQL-based Kinesis Data Analytics application.
module KinesisFirehoseOutputDescription =
Awso_kinesisanalyticsv2.Values.KinesisFirehoseOutputDescriptionFor a SQL-based Kinesis Data Analytics application's output, describes the Kinesis Data Firehose delivery stream that is configured as its destination.
module KinesisStreamsOutputDescription =
Awso_kinesisanalyticsv2.Values.KinesisStreamsOutputDescriptionFor an SQL-based Kinesis Data Analytics application's output, describes the Kinesis data stream that is configured as its destination.
For a SQL-based Kinesis Data Analytics application's output, describes the Amazon Lambda function that is configured as its destination.
module S3ReferenceDataSourceDescription =
Awso_kinesisanalyticsv2.Values.S3ReferenceDataSourceDescriptionFor a SQL-based Kinesis Data Analytics application, provides the bucket name and object key name that stores the reference data.
The information required to specify a Maven reference. You can use Maven references to specify dependency JAR files.
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.
For a SQL-based Kinesis Data Analytics application, represents an update to the InputLambdaProcessor that is used to preprocess the records in the stream.
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.
module S3ApplicationCodeLocationDescription =
Awso_kinesisanalyticsv2.Values.S3ApplicationCodeLocationDescriptionDescribes the location of an application's code stored in an S3 bucket.
Property key-value pairs passed into an application.
Describes the application input configuration for a SQL-based Kinesis Data Analytics application.
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.
module ReferenceDataSourceDescription =
Awso_kinesisanalyticsv2.Values.ReferenceDataSourceDescriptionFor a SQL-based Kinesis Data Analytics application, describes the reference data source configured for an application.
module GlueDataCatalogConfigurationDescription =
Awso_kinesisanalyticsv2.Values.GlueDataCatalogConfigurationDescriptionThe configuration of the Glue Data Catalog that you use for Apache Flink SQL queries and table API transforms that you write in an application.
module CustomArtifactConfigurationDescription =
Awso_kinesisanalyticsv2.Values.CustomArtifactConfigurationDescriptionSpecifies a dependency JAR or a JAR of user-defined functions.
module S3ContentBaseLocationDescription =
Awso_kinesisanalyticsv2.Values.S3ContentBaseLocationDescriptionThe description of the S3 base location that holds the application.
For a SQL-based Kinesis Data Analytics application, provides updates to the parallelism count.
module InputProcessingConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.InputProcessingConfigurationUpdateFor a SQL-based Kinesis Data Analytics application, describes updates to an InputProcessingConfiguration.
Describes updates for an SQL-based Kinesis Data Analytics application's input schema.
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.
When you update the input configuration for a SQL-based Kinesis Data Analytics application, provides information about a Kinesis stream as the streaming source.
module KinesisFirehoseOutputUpdate =
Awso_kinesisanalyticsv2.Values.KinesisFirehoseOutputUpdateFor 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.
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.
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.
module S3ReferenceDataSourceUpdate =
Awso_kinesisanalyticsv2.Values.S3ReferenceDataSourceUpdateFor a SQL-based Kinesis Data Analytics application, describes the Amazon S3 bucket name and object key name for an in-application reference table.
module InputProcessingConfiguration =
Awso_kinesisanalyticsv2.Values.InputProcessingConfigurationFor 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.
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).
Identifies a Kinesis data stream as the streaming source. You provide the stream's Amazon Resource Name (ARN).
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.
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).
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.
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.
Describes details about the code of a Managed Service for Apache Flink application.
module CheckpointConfigurationDescription =
Awso_kinesisanalyticsv2.Values.CheckpointConfigurationDescriptionDescribes checkpointing parameters for a Managed Service for Apache Flink application.
module MonitoringConfigurationDescription =
Awso_kinesisanalyticsv2.Values.MonitoringConfigurationDescriptionDescribes configuration parameters for CloudWatch logging for an application.
module ParallelismConfigurationDescription =
Awso_kinesisanalyticsv2.Values.ParallelismConfigurationDescriptionDescribes parameters for how a Managed Service for Apache Flink application executes multiple tasks simultaneously.
module ApplicationRestoreConfiguration =
Awso_kinesisanalyticsv2.Values.ApplicationRestoreConfigurationSpecifies the method and snapshot to use when restarting an application using previously saved application state.
Describes the starting parameters for a Managed Service for Apache Flink application.
module ReferenceDataSourceDescriptions =
Awso_kinesisanalyticsv2.Values.ReferenceDataSourceDescriptionsmodule VpcConfigurationDescription =
Awso_kinesisanalyticsv2.Values.VpcConfigurationDescriptionDescribes the parameters of a VPC used by the application.
module CatalogConfigurationDescription =
Awso_kinesisanalyticsv2.Values.CatalogConfigurationDescriptionThe 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.
module CustomArtifactsConfigurationDescriptionList =
Awso_kinesisanalyticsv2.Values.CustomArtifactsConfigurationDescriptionListmodule DeployAsApplicationConfigurationDescription =
Awso_kinesisanalyticsv2.Values.DeployAsApplicationConfigurationDescriptionThe configuration information required to deploy an Amazon Data Analytics Studio notebook as an application with durable state.
module ZeppelinMonitoringConfigurationDescription =
Awso_kinesisanalyticsv2.Values.ZeppelinMonitoringConfigurationDescriptionThe monitoring configuration for Apache Zeppelin within a Managed Service for Apache Flink Studio notebook.
Describes an update for the Amazon S3 code content location for an application.
For a SQL-based Kinesis Data Analytics application, describes updates to a specific input configuration (identified by the InputId of an application).
For a SQL-based Kinesis Data Analytics application, describes updates to the output configuration identified by the OutputId.
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.
module GlueDataCatalogConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.GlueDataCatalogConfigurationUpdateUpdates 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.
module CustomArtifactConfiguration =
Awso_kinesisanalyticsv2.Values.CustomArtifactConfigurationSpecifies dependency JARs, as well as JAR files that contain user-defined functions (UDF).
module S3ContentBaseLocationUpdate =
Awso_kinesisanalyticsv2.Values.S3ContentBaseLocationUpdateThe information required to update the S3 base location that holds the application.
An error message that is returned when an operation fails.
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.
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.
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.
module GlueDataCatalogConfiguration =
Awso_kinesisanalyticsv2.Values.GlueDataCatalogConfigurationThe configuration of the Glue Data Catalog that you use for Apache Flink SQL queries and table API transforms that you write in an application.
The S3 bucket that holds the application information.
module ApplicationCodeConfigurationDescription =
Awso_kinesisanalyticsv2.Values.ApplicationCodeConfigurationDescriptionDescribes code configuration for an application.
module ApplicationEncryptionConfigurationDescription =
Awso_kinesisanalyticsv2.Values.ApplicationEncryptionConfigurationDescriptionDescribes the encryption at rest configuration.
module ApplicationSnapshotConfigurationDescription =
Awso_kinesisanalyticsv2.Values.ApplicationSnapshotConfigurationDescriptionDescribes whether snapshots are enabled for a Managed Service for Apache Flink application.
module ApplicationSystemRollbackConfigurationDescription =
Awso_kinesisanalyticsv2.Values.ApplicationSystemRollbackConfigurationDescriptionDescribes the system rollback configuration for a Managed Service for Apache Flink application.
module EnvironmentPropertyDescriptions =
Awso_kinesisanalyticsv2.Values.EnvironmentPropertyDescriptionsDescribes the execution properties for an Apache Flink runtime.
module FlinkApplicationConfigurationDescription =
Awso_kinesisanalyticsv2.Values.FlinkApplicationConfigurationDescriptionDescribes configuration parameters for a Managed Service for Apache Flink application.
module RunConfigurationDescription =
Awso_kinesisanalyticsv2.Values.RunConfigurationDescriptionDescribes the starting properties for a Managed Service for Apache Flink application.
module SqlApplicationConfigurationDescription =
Awso_kinesisanalyticsv2.Values.SqlApplicationConfigurationDescriptionDescribes the inputs, outputs, and reference data sources for a SQL-based Kinesis Data Analytics application.
module VpcConfigurationDescriptions =
Awso_kinesisanalyticsv2.Values.VpcConfigurationDescriptionsmodule ZeppelinApplicationConfigurationDescription =
Awso_kinesisanalyticsv2.Values.ZeppelinApplicationConfigurationDescriptionThe configuration of a Managed Service for Apache Flink Studio notebook.
module ApplicationMaintenanceWindowEndTime =
Awso_kinesisanalyticsv2.Values.ApplicationMaintenanceWindowEndTimemodule ApplicationMaintenanceWindowStartTime =
Awso_kinesisanalyticsv2.Values.ApplicationMaintenanceWindowStartTimemodule CloudWatchLoggingOptionDescription =
Awso_kinesisanalyticsv2.Values.CloudWatchLoggingOptionDescriptionDescribes the Amazon CloudWatch logging option.
Describes an update to the code of an application. Not supported for Apache Zeppelin.
module CheckpointConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.CheckpointConfigurationUpdateDescribes updates to the checkpointing parameters for a Managed Service for Apache Flink application.
module MonitoringConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.MonitoringConfigurationUpdateDescribes updates to configuration parameters for Amazon CloudWatch logging for an application.
module ParallelismConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.ParallelismConfigurationUpdateDescribes updates to parameters for how an application executes multiple tasks simultaneously.
Describes updates to the VPC configuration used by the application.
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.
module CustomArtifactsConfigurationList =
Awso_kinesisanalyticsv2.Values.CustomArtifactsConfigurationListmodule DeployAsApplicationConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.DeployAsApplicationConfigurationUpdateUpdates to the configuration information required to deploy an Amazon Data Analytics Studio notebook as an application with durable state.
module ZeppelinMonitoringConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.ZeppelinMonitoringConfigurationUpdateUpdates to the monitoring configuration for Apache Zeppelin within a Managed Service for Apache Flink Studio notebook.
Describes the starting parameters for a SQL-based Kinesis Data Analytics application.
The name of the application.
The type of operation that is performed on an application.
The operation ID of the request.
A description of the error that caused an operation to fail.
Specifies either the application code, or the location of the application code, for a Managed Service for Apache Flink application.
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.
Describes configuration parameters for Amazon CloudWatch logging for an application. For more information about CloudWatch logging, see Monitoring.
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.
Describes the parameters of a VPC used by the application.
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.
module DeployAsApplicationConfiguration =
Awso_kinesisanalyticsv2.Values.DeployAsApplicationConfigurationThe information required to deploy a Managed Service for Apache Flink Studio notebook as an application with durable state.
module ZeppelinMonitoringConfiguration =
Awso_kinesisanalyticsv2.Values.ZeppelinMonitoringConfigurationDescribes configuration parameters for Amazon CloudWatch logging for a Managed Service for Apache Flink Studio notebook. For more information about CloudWatch logging, see Monitoring.
module ApplicationConfigurationDescription =
Awso_kinesisanalyticsv2.Values.ApplicationConfigurationDescriptionDescribes details about the application code and starting parameters for a Managed Service for Apache Flink application.
module ApplicationMaintenanceConfigurationDescription =
Awso_kinesisanalyticsv2.Values.ApplicationMaintenanceConfigurationDescriptionThe details of the maintenance configuration for the application.
module CloudWatchLoggingOptionDescriptions =
Awso_kinesisanalyticsv2.Values.CloudWatchLoggingOptionDescriptionsmodule ApplicationCodeConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.ApplicationCodeConfigurationUpdateDescribes 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.
module ApplicationEncryptionConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.ApplicationEncryptionConfigurationUpdateDescribes configuration updates to encryption at rest.
module ApplicationSnapshotConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.ApplicationSnapshotConfigurationUpdateDescribes updates to whether snapshots are enabled for a Managed Service for Apache Flink application.
module ApplicationSystemRollbackConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.ApplicationSystemRollbackConfigurationUpdateDescribes the system rollback configuration for a Managed Service for Apache Flink application.
Describes updates to the execution property groups for a Managed Service for Apache Flink application or a Studio notebook.
module FlinkApplicationConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.FlinkApplicationConfigurationUpdateDescribes updates to the configuration parameters for a Managed Service for Apache Flink application.
module SqlApplicationConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.SqlApplicationConfigurationUpdateDescribes updates to the input streams, destination streams, and reference data sources for a SQL-based Kinesis Data Analytics application.
module ZeppelinApplicationConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.ZeppelinApplicationConfigurationUpdateUpdates to the configuration of Managed Service for Apache Flink Studio notebook.
module CloudWatchLoggingOptionUpdate =
Awso_kinesisanalyticsv2.Values.CloudWatchLoggingOptionUpdateDescribes the Amazon CloudWatch logging option updates.
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.
Provides application summary information, including the application Amazon Resource Name (ARN), name, and status.
The summary of the application version.
Provides details about a snapshot of application state.
A description of the aplication operation that provides information about the updates that were made to the application.
module ApplicationVersionChangeDetails =
Awso_kinesisanalyticsv2.Values.ApplicationVersionChangeDetailsContains information about the version changes that the operation applied to the application.
Provides a description of the operation failure.
module ApplicationCodeConfiguration =
Awso_kinesisanalyticsv2.Values.ApplicationCodeConfigurationDescribes code configuration for an application.
module ApplicationEncryptionConfiguration =
Awso_kinesisanalyticsv2.Values.ApplicationEncryptionConfigurationSpecifies the configuration to manage encryption at rest.
module ApplicationSnapshotConfiguration =
Awso_kinesisanalyticsv2.Values.ApplicationSnapshotConfigurationDescribes whether snapshots are enabled for a Managed Service for Apache Flink application.
module ApplicationSystemRollbackConfiguration =
Awso_kinesisanalyticsv2.Values.ApplicationSystemRollbackConfigurationDescribes the system rollback configuration for a Managed Service for Apache Flink application.
Describes execution properties for a Managed Service for Apache Flink application.
module FlinkApplicationConfiguration =
Awso_kinesisanalyticsv2.Values.FlinkApplicationConfigurationDescribes configuration parameters for a Managed Service for Apache Flink application or a Studio notebook.
module SqlApplicationConfiguration =
Awso_kinesisanalyticsv2.Values.SqlApplicationConfigurationDescribes the inputs, outputs, and reference data sources for a SQL-based Kinesis Data Analytics application.
module ZeppelinApplicationConfiguration =
Awso_kinesisanalyticsv2.Values.ZeppelinApplicationConfigurationThe configuration of a Managed Service for Apache Flink Studio notebook.
Provides a description of Amazon CloudWatch logging options, including the log stream Amazon Resource Name (ARN).
Describes the application, including the application Amazon Resource Name (ARN), status, latest version, and input and output configurations.
The user-provided application code (query) is not valid. This can be a simple syntax error.
module ConcurrentModificationException =
Awso_kinesisanalyticsv2.Values.ConcurrentModificationExceptionException 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.
module InvalidApplicationConfigurationException =
Awso_kinesisanalyticsv2.Values.InvalidApplicationConfigurationExceptionThe user-provided application configuration is not valid.
The specified input parameter value is not valid.
The request JSON is not valid for the operation.
The number of allowed resources has been exceeded.
The application is not available for this operation.
Specified application can't be found.
module ApplicationConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.ApplicationConfigurationUpdateDescribes updates to an application's configuration.
module CloudWatchLoggingOptionUpdates =
Awso_kinesisanalyticsv2.Values.CloudWatchLoggingOptionUpdatesDescribes the updates to the starting parameters for a Managed Service for Apache Flink application.
module UnsupportedOperationException =
Awso_kinesisanalyticsv2.Values.UnsupportedOperationExceptionThe request was rejected because a specified parameter is not supported or a specified resource is not valid for this operation.
module ApplicationMaintenanceConfigurationUpdate =
Awso_kinesisanalyticsv2.Values.ApplicationMaintenanceConfigurationUpdateDescribes the updated maintenance configuration for the application.
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.
Describes the starting parameters for an Managed Service for Apache Flink application.
module ApplicationVersionSummaries =
Awso_kinesisanalyticsv2.Values.ApplicationVersionSummariesA pagination token that can be used in a subsequent request.
module ListApplicationVersionsInputLimit =
Awso_kinesisanalyticsv2.Values.ListApplicationVersionsInputLimitmodule ApplicationOperationInfoList =
Awso_kinesisanalyticsv2.Values.ApplicationOperationInfoListmodule ListApplicationOperationsInputLimit =
Awso_kinesisanalyticsv2.Values.ListApplicationOperationsInputLimitThe limit on the number of records to be returned in the response.
module ResourceProvisionedThroughputExceededException =
Awso_kinesisanalyticsv2.Values.ResourceProvisionedThroughputExceededExceptionDiscovery 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.
The service cannot complete the request.
module UnableToDetectSchemaException =
Awso_kinesisanalyticsv2.Values.UnableToDetectSchemaExceptionThe data format is not valid. Kinesis Data Analytics cannot detect the schema for the given streaming source.
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.
module ApplicationOperationInfoDetails =
Awso_kinesisanalyticsv2.Values.ApplicationOperationInfoDetailsA description of the application operation that provides information about the updates that were made to the application.
Specifies the creation parameters for a Managed Service for Apache Flink application.
module SessionExpirationDurationInSeconds =
Awso_kinesisanalyticsv2.Values.SessionExpirationDurationInSecondsUpdates 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.
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.
module UpdateApplicationMaintenanceConfigurationResponse =
Awso_kinesisanalyticsv2.Values.UpdateApplicationMaintenanceConfigurationResponseUpdates 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.
module UpdateApplicationMaintenanceConfigurationRequest =
Awso_kinesisanalyticsv2.Values.UpdateApplicationMaintenanceConfigurationRequestUpdates 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.
Removes one or more tags from a Managed Service for Apache Flink application. For more information, see Using Tagging.
Removes one or more tags from a Managed Service for Apache Flink application. For more information, see Using Tagging.
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.
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.
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.
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.
Starts the specified Managed Service for Apache Flink application. After creating an application, you must exclusively call this operation to start your application.
Starts the specified Managed Service for Apache Flink application. After creating an application, you must exclusively call this operation to start your application.
module RollbackApplicationResponse =
Awso_kinesisanalyticsv2.Values.RollbackApplicationResponseReverts 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.
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.
module ListTagsForResourceResponse =
Awso_kinesisanalyticsv2.Values.ListTagsForResourceResponseRetrieves the list of key-value tags assigned to the application. For more information, see Using Tagging.
Retrieves the list of key-value tags assigned to the application. For more information, see Using Tagging.
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.
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.
module ListApplicationVersionsResponse =
Awso_kinesisanalyticsv2.Values.ListApplicationVersionsResponseLists 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.
module ListApplicationVersionsRequest =
Awso_kinesisanalyticsv2.Values.ListApplicationVersionsRequestLists 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.
module ListApplicationSnapshotsResponse =
Awso_kinesisanalyticsv2.Values.ListApplicationSnapshotsResponseLists information about the current application snapshots.
module ListApplicationSnapshotsRequest =
Awso_kinesisanalyticsv2.Values.ListApplicationSnapshotsRequestLists information about the current application snapshots.
module ListApplicationOperationsResponse =
Awso_kinesisanalyticsv2.Values.ListApplicationOperationsResponseA response that returns a list of operations for an application.
module ListApplicationOperationsRequest =
Awso_kinesisanalyticsv2.Values.ListApplicationOperationsRequestA request for a list of operations performed on an application.
module DiscoverInputSchemaResponse =
Awso_kinesisanalyticsv2.Values.DiscoverInputSchemaResponseInfers 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.
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.
module DescribeApplicationVersionResponse =
Awso_kinesisanalyticsv2.Values.DescribeApplicationVersionResponseProvides 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.
module DescribeApplicationVersionRequest =
Awso_kinesisanalyticsv2.Values.DescribeApplicationVersionRequestProvides 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.
module DescribeApplicationSnapshotResponse =
Awso_kinesisanalyticsv2.Values.DescribeApplicationSnapshotResponseReturns information about a snapshot of application state data.
module DescribeApplicationSnapshotRequest =
Awso_kinesisanalyticsv2.Values.DescribeApplicationSnapshotRequestReturns information about a snapshot of application state data.
module DescribeApplicationResponse =
Awso_kinesisanalyticsv2.Values.DescribeApplicationResponseReturns 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.
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.
module DescribeApplicationOperationResponse =
Awso_kinesisanalyticsv2.Values.DescribeApplicationOperationResponseProvides details of the operation that corresponds to the operation ID on a Managed Service for Apache Flink application.
module DescribeApplicationOperationRequest =
Awso_kinesisanalyticsv2.Values.DescribeApplicationOperationRequestA request for information about a specific operation that was performed on a Managed Service for Apache Flink application.
module DeleteApplicationVpcConfigurationResponse =
Awso_kinesisanalyticsv2.Values.DeleteApplicationVpcConfigurationResponseRemoves a VPC configuration from a Managed Service for Apache Flink application.
module DeleteApplicationVpcConfigurationRequest =
Awso_kinesisanalyticsv2.Values.DeleteApplicationVpcConfigurationRequestRemoves a VPC configuration from a Managed Service for Apache Flink application.
module DeleteApplicationSnapshotResponse =
Awso_kinesisanalyticsv2.Values.DeleteApplicationSnapshotResponseDeletes a snapshot of application state.
module DeleteApplicationSnapshotRequest =
Awso_kinesisanalyticsv2.Values.DeleteApplicationSnapshotRequestDeletes a snapshot of application state.
Deletes the specified application. Managed Service for Apache Flink halts application execution and deletes the application.
Deletes the specified application. Managed Service for Apache Flink halts application execution and deletes the application.
module DeleteApplicationReferenceDataSourceResponse =
Awso_kinesisanalyticsv2.Values.DeleteApplicationReferenceDataSourceResponseDeletes 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.
module DeleteApplicationReferenceDataSourceRequest =
Awso_kinesisanalyticsv2.Values.DeleteApplicationReferenceDataSourceRequestDeletes 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.
module DeleteApplicationOutputResponse =
Awso_kinesisanalyticsv2.Values.DeleteApplicationOutputResponseDeletes 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.
module DeleteApplicationOutputRequest =
Awso_kinesisanalyticsv2.Values.DeleteApplicationOutputRequestDeletes 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.
module DeleteApplicationInputProcessingConfigurationResponse =
Awso_kinesisanalyticsv2.Values.DeleteApplicationInputProcessingConfigurationResponseDeletes an InputProcessingConfiguration from an input.
module DeleteApplicationInputProcessingConfigurationRequest =
Awso_kinesisanalyticsv2.Values.DeleteApplicationInputProcessingConfigurationRequestDeletes an InputProcessingConfiguration from an input.
module DeleteApplicationCloudWatchLoggingOptionResponse =
Awso_kinesisanalyticsv2.Values.DeleteApplicationCloudWatchLoggingOptionResponseDeletes an Amazon CloudWatch log stream from an SQL-based Kinesis Data Analytics application.
module DeleteApplicationCloudWatchLoggingOptionRequest =
Awso_kinesisanalyticsv2.Values.DeleteApplicationCloudWatchLoggingOptionRequestDeletes an Amazon CloudWatch log stream from an SQL-based Kinesis Data Analytics application.
module CreateApplicationSnapshotResponse =
Awso_kinesisanalyticsv2.Values.CreateApplicationSnapshotResponseCreates a snapshot of the application's state data.
module CreateApplicationSnapshotRequest =
Awso_kinesisanalyticsv2.Values.CreateApplicationSnapshotRequestCreates a snapshot of the application's state data.
Creates a Managed Service for Apache Flink application. For information about creating a Managed Service for Apache Flink application, see Creating an Application.
Creates a Managed Service for Apache Flink application. For information about creating a Managed Service for Apache Flink application, see Creating an Application.
module CreateApplicationPresignedUrlResponse =
Awso_kinesisanalyticsv2.Values.CreateApplicationPresignedUrlResponseCreates 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.
module CreateApplicationPresignedUrlRequest =
Awso_kinesisanalyticsv2.Values.CreateApplicationPresignedUrlRequestCreates 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.
module AddApplicationVpcConfigurationResponse =
Awso_kinesisanalyticsv2.Values.AddApplicationVpcConfigurationResponseAdds 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.
module AddApplicationVpcConfigurationRequest =
Awso_kinesisanalyticsv2.Values.AddApplicationVpcConfigurationRequestAdds 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.
module AddApplicationReferenceDataSourceResponse =
Awso_kinesisanalyticsv2.Values.AddApplicationReferenceDataSourceResponseAdds 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.
module AddApplicationReferenceDataSourceRequest =
Awso_kinesisanalyticsv2.Values.AddApplicationReferenceDataSourceRequestAdds 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.
module AddApplicationOutputResponse =
Awso_kinesisanalyticsv2.Values.AddApplicationOutputResponseAdds 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.
module AddApplicationOutputRequest =
Awso_kinesisanalyticsv2.Values.AddApplicationOutputRequestAdds 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.
module AddApplicationInputResponse =
Awso_kinesisanalyticsv2.Values.AddApplicationInputResponseAdds 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.
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.
module AddApplicationInputProcessingConfigurationResponse =
Awso_kinesisanalyticsv2.Values.AddApplicationInputProcessingConfigurationResponseAdds 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.
module AddApplicationInputProcessingConfigurationRequest =
Awso_kinesisanalyticsv2.Values.AddApplicationInputProcessingConfigurationRequestAdds 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.
module AddApplicationCloudWatchLoggingOptionResponse =
Awso_kinesisanalyticsv2.Values.AddApplicationCloudWatchLoggingOptionResponseAdds an Amazon CloudWatch log stream to monitor application configuration errors.
module AddApplicationCloudWatchLoggingOptionRequest =
Awso_kinesisanalyticsv2.Values.AddApplicationCloudWatchLoggingOptionRequestAdds an Amazon CloudWatch log stream to monitor application configuration errors.