Module Smaws_Client_KinesisAnalyticsV2.Types

type nonrec zip_file_content = bytes
type nonrec log_level =
  1. | DEBUG
  2. | ERROR
  3. | WARN
  4. | INFO
type nonrec zeppelin_monitoring_configuration_update = {
  1. log_level_update : log_level;
    (*

    Updates to the logging level for Apache Zeppelin within a Managed Service for Apache Flink Studio notebook.

    *)
}

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

type nonrec zeppelin_monitoring_configuration_description = {
  1. log_level : log_level option;
    (*

    Describes the verbosity of the CloudWatch Logs for an application.

    *)
}

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

type nonrec zeppelin_monitoring_configuration = {
  1. log_level : log_level;
    (*

    The verbosity of the CloudWatch Logs for an application.

    *)
}

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

type nonrec database_ar_n = string
type nonrec glue_data_catalog_configuration_update = {
  1. database_arn_update : database_ar_n;
    (*

    The updated Amazon Resource Name (ARN) of the database.

    *)
}

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.

type nonrec catalog_configuration_update = {
  1. glue_data_catalog_configuration_update : glue_data_catalog_configuration_update;
    (*

    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.

    *)
}

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.

type nonrec bucket_ar_n = string
type nonrec base_path = string
type nonrec s3_content_base_location_update = {
  1. base_path_update : base_path option;
    (*

    The updated S3 bucket path.

    *)
  2. bucket_arn_update : bucket_ar_n option;
    (*

    The updated Amazon Resource Name (ARN) of the S3 bucket.

    *)
}

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

type nonrec deploy_as_application_configuration_update = {
  1. s3_content_location_update : s3_content_base_location_update option;
    (*

    Updates to the location that holds the data required to specify an Amazon Data Analytics application.

    *)
}

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

type nonrec artifact_type =
  1. | DEPENDENCY_JAR
  2. | UDF
type nonrec file_key = string
type nonrec object_version = string
type nonrec s3_content_location = {
  1. object_version : object_version option;
    (*

    The version of the object containing the application code.

    *)
  2. file_key : file_key;
    (*

    The file key for the object containing the application code.

    *)
  3. bucket_ar_n : bucket_ar_n;
    (*

    The Amazon Resource Name (ARN) for the S3 bucket containing the application code.

    *)
}

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.

type nonrec maven_group_id = string
type nonrec maven_artifact_id = string
type nonrec maven_version = string
type nonrec maven_reference = {
  1. version : maven_version;
    (*

    The version of the Maven reference.

    *)
  2. artifact_id : maven_artifact_id;
    (*

    The artifact ID of the Maven reference.

    *)
  3. group_id : maven_group_id;
    (*

    The group ID of the Maven reference.

    *)
}

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

type nonrec custom_artifact_configuration = {
  1. maven_reference : maven_reference option;
    (*

    The parameters required to fully specify a Maven reference.

    *)
  2. s3_content_location : s3_content_location option;
  3. artifact_type : artifact_type;
    (*

    UDF stands for user-defined functions. This type of artifact must be in an S3 bucket. A DEPENDENCY_JAR can be in either Maven or an S3 bucket.

    *)
}

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

type nonrec custom_artifacts_configuration_list = custom_artifact_configuration list
type nonrec zeppelin_application_configuration_update = {
  1. custom_artifacts_configuration_update : custom_artifacts_configuration_list option;
    (*

    Updates to the customer artifacts. Custom artifacts are dependency JAR files and user-defined functions (UDF).

    *)
  2. deploy_as_application_configuration_update : deploy_as_application_configuration_update option;
  3. catalog_configuration_update : catalog_configuration_update option;
    (*

    Updates to the configuration of the Amazon Glue Data Catalog that is associated with the Managed Service for Apache Flink Studio notebook.

    *)
  4. monitoring_configuration_update : zeppelin_monitoring_configuration_update option;
    (*

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

    *)
}

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

type nonrec glue_data_catalog_configuration_description = {
  1. database_ar_n : database_ar_n;
    (*

    The Amazon Resource Name (ARN) of the database.

    *)
}

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.

type nonrec catalog_configuration_description = {
  1. glue_data_catalog_configuration_description : glue_data_catalog_configuration_description;
    (*

    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.

    *)
}

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.

type nonrec s3_content_base_location_description = {
  1. base_path : base_path option;
    (*

    The base path for the S3 bucket.

    *)
  2. bucket_ar_n : bucket_ar_n;
    (*

    The Amazon Resource Name (ARN) of the S3 bucket.

    *)
}

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

type nonrec deploy_as_application_configuration_description = {
  1. s3_content_location_description : s3_content_base_location_description;
    (*

    The location that holds the data required to specify an Amazon Data Analytics application.

    *)
}

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

type nonrec custom_artifact_configuration_description = {
  1. maven_reference_description : maven_reference option;
    (*

    The parameters that are required to specify a Maven dependency.

    *)
  2. s3_content_location_description : s3_content_location option;
  3. artifact_type : artifact_type option;
    (*

    UDF stands for user-defined functions. This type of artifact must be in an S3 bucket. A DEPENDENCY_JAR can be in either Maven or an S3 bucket.

    *)
}

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

type nonrec custom_artifacts_configuration_description_list = custom_artifact_configuration_description list
type nonrec zeppelin_application_configuration_description = {
  1. custom_artifacts_configuration_description : custom_artifacts_configuration_description_list option;
    (*

    Custom artifacts are dependency JARs and user-defined functions (UDF).

    *)
  2. deploy_as_application_configuration_description : deploy_as_application_configuration_description option;
    (*

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

    *)
  3. catalog_configuration_description : catalog_configuration_description option;
    (*

    The Amazon Glue Data Catalog that is associated with the Managed Service for Apache Flink Studio notebook.

    *)
  4. monitoring_configuration_description : zeppelin_monitoring_configuration_description;
    (*

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

    *)
}

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

type nonrec glue_data_catalog_configuration = {
  1. database_ar_n : database_ar_n;
    (*

    The Amazon Resource Name (ARN) of the database.

    *)
}

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.

type nonrec catalog_configuration = {
  1. glue_data_catalog_configuration : glue_data_catalog_configuration;
    (*

    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.

    *)
}

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.

type nonrec s3_content_base_location = {
  1. base_path : base_path option;
    (*

    The base path for the S3 bucket.

    *)
  2. bucket_ar_n : bucket_ar_n;
    (*

    The Amazon Resource Name (ARN) of the S3 bucket.

    *)
}

The S3 bucket that holds the application information.

type nonrec deploy_as_application_configuration = {
  1. s3_content_location : s3_content_base_location;
    (*

    The description of an Amazon S3 object that contains the Amazon Data Analytics application, including the Amazon Resource Name (ARN) of the S3 bucket, the name of the Amazon S3 object that contains the data, and the version number of the Amazon S3 object that contains the data.

    *)
}

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

type nonrec zeppelin_application_configuration = {
  1. custom_artifacts_configuration : custom_artifacts_configuration_list option;
    (*

    Custom artifacts are dependency JARs and user-defined functions (UDF).

    *)
  2. deploy_as_application_configuration : deploy_as_application_configuration option;
    (*

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

    *)
  3. catalog_configuration : catalog_configuration option;
    (*

    The Amazon Glue Data Catalog that you use in queries in a Managed Service for Apache Flink Studio notebook.

    *)
  4. monitoring_configuration : zeppelin_monitoring_configuration option;
    (*

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

    *)
}

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

type nonrec vpc_id = string
type nonrec subnet_id = string
type nonrec subnet_ids = subnet_id list
type nonrec security_group_id = string
type nonrec security_group_ids = security_group_id list
type nonrec vpc_configuration = {
  1. security_group_ids : security_group_ids;
    (*

    The array of SecurityGroup IDs used by the VPC configuration.

    *)
  2. subnet_ids : subnet_ids;
    (*

    The array of Subnet IDs used by the VPC configuration.

    *)
}

Describes the parameters of a VPC used by the application.

type nonrec vpc_configurations = vpc_configuration list
type nonrec id = string
type nonrec vpc_configuration_update = {
  1. security_group_id_updates : security_group_ids option;
    (*

    Describes updates to the array of SecurityGroup IDs used by the VPC configuration.

    *)
  2. subnet_id_updates : subnet_ids option;
    (*

    Describes updates to the array of Subnet IDs used by the VPC configuration.

    *)
  3. vpc_configuration_id : id;
    (*

    Describes an update to the ID of the VPC configuration.

    *)
}

Describes updates to the VPC configuration used by the application.

type nonrec vpc_configuration_updates = vpc_configuration_update list
type nonrec vpc_configuration_description = {
  1. security_group_ids : security_group_ids;
    (*

    The array of SecurityGroup IDs used by the VPC configuration.

    *)
  2. subnet_ids : subnet_ids;
    (*

    The array of Subnet IDs used by the VPC configuration.

    *)
  3. vpc_id : vpc_id;
    (*

    The ID of the associated VPC.

    *)
  4. vpc_configuration_id : id;
    (*

    The ID of the VPC configuration.

    *)
}

Describes the parameters of a VPC used by the application.

type nonrec vpc_configuration_descriptions = vpc_configuration_description list
type nonrec url_type =
  1. | ZEPPELIN_UI_URL
type nonrec resource_ar_n = string
type nonrec application_description = string
type nonrec application_name = string
type nonrec runtime_environment =
  1. | SQL_1_0
type nonrec role_ar_n = string
type nonrec application_status =
  1. | ROLLED_BACK
  2. | MAINTENANCE
  3. | ROLLING_BACK
  4. | FORCE_STOPPING
  5. | AUTOSCALING
  6. | UPDATING
  7. | RUNNING
  8. | READY
  9. | STOPPING
  10. | STARTING
  11. | DELETING
type nonrec application_version_id = int
type nonrec timestamp = Smaws_Lib.CoreTypes.Timestamp.t
type nonrec in_app_stream_name = string
type nonrec in_app_stream_names = in_app_stream_name list
type nonrec input_lambda_processor_description = {
  1. role_ar_n : role_ar_n option;
    (*

    The ARN of the IAM role that is used to access the Amazon Lambda function.

    Provided for backward compatibility. Applications that are created with the current API version have an application-level service execution role rather than a resource-level role.

    *)
  2. resource_ar_n : resource_ar_n;
    (*

    The ARN of the Amazon Lambda function that is used to preprocess the records in the stream.

    To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: Amazon Lambda

    *)
}

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.

type nonrec input_processing_configuration_description = {
  1. input_lambda_processor_description : input_lambda_processor_description option;
    (*

    Provides configuration information about the associated InputLambdaProcessorDescription

    *)
}

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.

type nonrec kinesis_streams_input_description = {
  1. role_ar_n : role_ar_n option;
    (*

    The ARN of the IAM role that Kinesis Data Analytics can assume to access the stream.

    Provided for backward compatibility. Applications that are created with the current API version have an application-level service execution role rather than a resource-level role.

    *)
  2. resource_ar_n : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the Kinesis data stream.

    *)
}

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.

type nonrec kinesis_firehose_input_description = {
  1. role_ar_n : role_ar_n option;
    (*

    The ARN of the IAM role that Kinesis Data Analytics assumes to access the stream.

    Provided for backward compatibility. Applications that are created with the current API version have an application-level service execution role rather than a resource-level role.

    *)
  2. resource_ar_n : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the delivery stream.

    *)
}

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

type nonrec record_format_type =
  1. | CSV
  2. | JSON
type nonrec record_row_path = string
type nonrec json_mapping_parameters = {
  1. record_row_path : record_row_path;
    (*

    The path to the top-level parent that contains the records.

    *)
}

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

type nonrec record_row_delimiter = string
type nonrec record_column_delimiter = string
type nonrec csv_mapping_parameters = {
  1. record_column_delimiter : record_column_delimiter;
    (*

    The column delimiter. For example, in a CSV format, a comma (",") is the typical column delimiter.

    *)
  2. record_row_delimiter : record_row_delimiter;
    (*

    The row delimiter. For example, in a CSV format, '\n' is the typical row delimiter.

    *)
}

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"

type nonrec mapping_parameters = {
  1. csv_mapping_parameters : csv_mapping_parameters option;
    (*

    Provides additional mapping information when the record format uses delimiters (for example, CSV).

    *)
  2. json_mapping_parameters : json_mapping_parameters option;
    (*

    Provides additional mapping information when JSON is the record format on the streaming 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.

type nonrec record_format = {
  1. mapping_parameters : mapping_parameters option;
    (*

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

    *)
  2. record_format_type : record_format_type;
    (*

    The type of record format.

    *)
}

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.

type nonrec record_encoding = string
type nonrec record_column_name = string
type nonrec record_column_mapping = string
type nonrec record_column_sql_type = string
type nonrec record_column = {
  1. sql_type : record_column_sql_type;
    (*

    The type of column created in the in-application input stream or reference table.

    *)
  2. mapping : record_column_mapping option;
    (*

    A reference to the data element in the streaming input or the reference data source.

    *)
  3. name : record_column_name;
    (*

    The name of the column that is created in the in-application input stream or reference table.

    *)
}

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.

type nonrec record_columns = record_column list
type nonrec source_schema = {
  1. record_columns : record_columns;
    (*

    A list of RecordColumn objects.

    *)
  2. record_encoding : record_encoding option;
    (*

    Specifies the encoding of the records in the streaming source. For example, UTF-8.

    *)
  3. record_format : record_format;
    (*

    Specifies the format of the records on the streaming source.

    *)
}

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.

type nonrec input_parallelism_count = int
type nonrec input_parallelism = {
  1. count : input_parallelism_count option;
    (*

    The number of in-application streams to create.

    *)
}

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

type nonrec input_starting_position =
  1. | LAST_STOPPED_POINT
  2. | TRIM_HORIZON
  3. | NOW
type nonrec input_starting_position_configuration = {
  1. input_starting_position : input_starting_position option;
    (*

    The starting position on the stream.

    • NOW - Start reading just after the most recent record in the stream, and start at the request timestamp that the customer issued.
    • TRIM_HORIZON - Start reading at the last untrimmed record in the stream, which is the oldest record available in the stream. This option is not available for an Amazon Kinesis Data Firehose delivery stream.
    • LAST_STOPPED_POINT - Resume reading from where the application last stopped reading.
    *)
}

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

type nonrec input_description = {
  1. input_starting_position_configuration : input_starting_position_configuration option;
    (*

    The point at which the application is configured to read from the input stream.

    *)
  2. input_parallelism : input_parallelism option;
    (*

    Describes the configured parallelism (number of in-application streams mapped to the streaming source).

    *)
  3. input_schema : source_schema option;
    (*

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

    *)
  4. kinesis_firehose_input_description : kinesis_firehose_input_description option;
    (*

    If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN.

    *)
  5. kinesis_streams_input_description : kinesis_streams_input_description option;
    (*

    If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource Name (ARN).

    *)
  6. input_processing_configuration_description : input_processing_configuration_description option;
    (*

    The description of the preprocessor that executes on records in this input before the application's code is run.

    *)
  7. in_app_stream_names : in_app_stream_names option;
    (*

    Returns the in-application stream names that are mapped to the stream source.

    *)
  8. name_prefix : in_app_stream_name option;
    (*

    The in-application name prefix.

    *)
  9. input_id : id option;
    (*

    The input ID that is associated with the application input. This is the ID that Kinesis Data Analytics assigns to each input configuration that you add to your application.

    *)
}

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

type nonrec input_descriptions = input_description list
type nonrec kinesis_streams_output_description = {
  1. role_ar_n : role_ar_n option;
    (*

    The ARN of the IAM role that Kinesis Data Analytics can assume to access the stream.

    Provided for backward compatibility. Applications that are created with the current API version have an application-level service execution role rather than a resource-level role.

    *)
  2. resource_ar_n : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the Kinesis data stream.

    *)
}

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

type nonrec kinesis_firehose_output_description = {
  1. role_ar_n : role_ar_n option;
    (*

    The ARN of the IAM role that Kinesis Data Analytics can assume to access the stream.

    Provided for backward compatibility. Applications that are created with the current API version have an application-level service execution role rather than a resource-level role.

    *)
  2. resource_ar_n : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the delivery stream.

    *)
}

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

type nonrec lambda_output_description = {
  1. role_ar_n : role_ar_n option;
    (*

    The ARN of the IAM role that Kinesis Data Analytics can assume to write to the destination function.

    Provided for backward compatibility. Applications that are created with the current API version have an application-level service execution role rather than a resource-level role.

    *)
  2. resource_ar_n : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the destination Lambda function.

    *)
}

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

type nonrec destination_schema = {
  1. record_format_type : record_format_type;
    (*

    Specifies the format of the records on the output stream.

    *)
}

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

type nonrec output_description = {
  1. destination_schema : destination_schema option;
    (*

    The data format used for writing data to the destination.

    *)
  2. lambda_output_description : lambda_output_description option;
    (*

    Describes the Lambda function that is configured as the destination where output is written.

    *)
  3. kinesis_firehose_output_description : kinesis_firehose_output_description option;
    (*

    Describes the Kinesis Data Firehose delivery stream that is configured as the destination where output is written.

    *)
  4. kinesis_streams_output_description : kinesis_streams_output_description option;
    (*

    Describes the Kinesis data stream that is configured as the destination where output is written.

    *)
  5. name : in_app_stream_name option;
    (*

    The name of the in-application stream that is configured as output.

    *)
  6. output_id : id option;
    (*

    A unique identifier for the output configuration.

    *)
}

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.

type nonrec output_descriptions = output_description list
type nonrec in_app_table_name = string
type nonrec s3_reference_data_source_description = {
  1. reference_role_ar_n : role_ar_n option;
    (*

    The ARN of the IAM role that Kinesis Data Analytics can assume to read the Amazon S3 object on your behalf to populate the in-application reference table.

    Provided for backward compatibility. Applications that are created with the current API version have an application-level service execution role rather than a resource-level role.

    *)
  2. file_key : file_key;
    (*

    Amazon S3 object key name.

    *)
  3. bucket_ar_n : bucket_ar_n;
    (*

    The Amazon Resource Name (ARN) of the S3 bucket.

    *)
}

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

type nonrec reference_data_source_description = {
  1. reference_schema : source_schema option;
    (*

    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.

    *)
  2. s3_reference_data_source_description : s3_reference_data_source_description;
    (*

    Provides the Amazon S3 bucket name, the object key name that contains the reference data.

    *)
  3. table_name : in_app_table_name;
    (*

    The in-application table name created by the specific reference data source configuration.

    *)
  4. reference_id : id;
    (*

    The ID of the reference data source. This is the ID that Kinesis Data Analytics assigns when you add the reference data source to your application using the CreateApplication or UpdateApplication operation.

    *)
}

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

type nonrec reference_data_source_descriptions = reference_data_source_description list
type nonrec sql_application_configuration_description = {
  1. reference_data_source_descriptions : reference_data_source_descriptions option;
    (*

    The array of ReferenceDataSourceDescription objects describing the reference data sources used by the application.

    *)
  2. output_descriptions : output_descriptions option;
    (*

    The array of OutputDescription objects describing the destination streams used by the application.

    *)
  3. input_descriptions : input_descriptions option;
    (*

    The array of InputDescription objects describing the input streams used by the application.

    *)
}

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

type nonrec code_content_type =
  1. | ZIPFILE
  2. | PLAINTEXT
type nonrec text_content = string
type nonrec code_m_d5 = string
type nonrec code_size = int
type nonrec s3_application_code_location_description = {
  1. object_version : object_version option;
    (*

    The version of the object containing the application code.

    *)
  2. file_key : file_key;
    (*

    The file key for the object containing the application code.

    *)
  3. bucket_ar_n : bucket_ar_n;
    (*

    The Amazon Resource Name (ARN) for the S3 bucket containing the application code.

    *)
}

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

type nonrec code_content_description = {
  1. s3_application_code_location_description : s3_application_code_location_description option;
    (*

    The S3 bucket Amazon Resource Name (ARN), file key, and object version of the application code stored in Amazon S3.

    *)
  2. code_size : code_size option;
    (*

    The size in bytes of the application code. Can be used to validate zip-format code.

    *)
  3. code_m_d5 : code_m_d5 option;
    (*

    The checksum that can be used to validate zip-format code.

    *)
  4. text_content : text_content option;
    (*

    The text-format code

    *)
}

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

type nonrec application_code_configuration_description = {
  1. code_content_description : code_content_description option;
    (*

    Describes details about the location and format of the application code.

    *)
  2. code_content_type : code_content_type;
    (*

    Specifies whether the code content is in text or zip format.

    *)
}

Describes code configuration for an application.

type nonrec application_restore_type =
  1. | RESTORE_FROM_CUSTOM_SNAPSHOT
  2. | RESTORE_FROM_LATEST_SNAPSHOT
  3. | SKIP_RESTORE_FROM_SNAPSHOT
type nonrec snapshot_name = string
type nonrec application_restore_configuration = {
  1. snapshot_name : snapshot_name option;
    (*

    The identifier of an existing snapshot of application state to use to restart an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT is specified for the ApplicationRestoreType.

    *)
  2. application_restore_type : application_restore_type;
    (*

    Specifies how the application should be restored.

    *)
}

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

type nonrec boolean_object = bool

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

type nonrec run_configuration_description = {
  1. application_restore_configuration_description : application_restore_configuration option;
    (*

    Describes the restore behavior of a restarting application.

    *)
}

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

type nonrec configuration_type =
  1. | CUSTOM
  2. | DEFAULT
type nonrec checkpoint_interval = int
type nonrec min_pause_between_checkpoints = int
type nonrec checkpoint_configuration_description = {
  1. min_pause_between_checkpoints : min_pause_between_checkpoints option;
    (*

    Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.

    If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a MinPauseBetweenCheckpoints value of 5000, even if this value is set using this API or in application code.

    *)
  2. checkpoint_interval : checkpoint_interval option;
    (*

    Describes the interval in milliseconds between checkpoint operations.

    If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointInterval value of 60000, even if this value is set to another value using this API or in application code.

    *)
  3. checkpointing_enabled : boolean_object option;
    (*

    Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.

    If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointingEnabled value of true, even if this value is set to another value using this API or in application code.

    *)
  4. configuration_type : configuration_type option;
    (*

    Describes whether the application uses the default checkpointing behavior in Managed Service for Apache Flink.

    If this value is set to DEFAULT, the application will use the following values, even if they are set to other values using APIs or application code:

    • CheckpointingEnabled: true
    • CheckpointInterval: 60000
    • MinPauseBetweenCheckpoints: 5000
    *)
}

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

type nonrec metrics_level =
  1. | PARALLELISM
  2. | OPERATOR
  3. | TASK
  4. | APPLICATION
type nonrec monitoring_configuration_description = {
  1. log_level : log_level option;
    (*

    Describes the verbosity of the CloudWatch Logs for an application.

    *)
  2. metrics_level : metrics_level option;
    (*

    Describes the granularity of the CloudWatch Logs for an application.

    *)
  3. configuration_type : configuration_type option;
    (*

    Describes whether to use the default CloudWatch logging configuration for an application.

    *)
}

Describes configuration parameters for CloudWatch logging for an application.

type nonrec parallelism = int
type nonrec parallelism_per_kp_u = int
type nonrec parallelism_configuration_description = {
  1. auto_scaling_enabled : boolean_object option;
    (*

    Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.

    *)
  2. current_parallelism : parallelism option;
    (*

    Describes the current number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, Managed Service for Apache Flink can increase this value in response to application load. The service can increase this value up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.

    *)
  3. parallelism_per_kp_u : parallelism_per_kp_u option;
    (*

    Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application.

    *)
  4. parallelism : parallelism option;
    (*

    Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, then Managed Service for Apache Flink can increase the CurrentParallelism value in response to application load. The service can increase CurrentParallelism up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.

    *)
  5. configuration_type : configuration_type option;
    (*

    Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.

    *)
}

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

type nonrec job_plan_description = string

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

type nonrec property_value = string
type nonrec property_key = string
type nonrec property_map = (property_key * property_value) list
type nonrec property_group = {
  1. property_map : property_map;
    (*

    Describes the value of an application execution property key-value pair.

    *)
  2. property_group_id : id;
    (*

    Describes the key of an application execution property key-value pair.

    *)
}

Property key-value pairs passed into an application.

type nonrec property_groups = property_group list
type nonrec environment_property_descriptions = {
  1. property_group_descriptions : property_groups option;
    (*

    Describes the execution property groups.

    *)
}

Describes the execution properties for an Apache Flink runtime.

type nonrec application_snapshot_configuration_description = {
  1. snapshots_enabled : boolean_object;
    (*

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

    *)
}

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

type nonrec application_system_rollback_configuration_description = {
  1. rollback_enabled : boolean_object;
    (*

    Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application

    *)
}

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

type nonrec application_configuration_description = {
  1. zeppelin_application_configuration_description : zeppelin_application_configuration_description option;
    (*

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

    *)
  2. vpc_configuration_descriptions : vpc_configuration_descriptions option;
    (*

    The array of descriptions of VPC configurations available to the application.

    *)
  3. application_system_rollback_configuration_description : application_system_rollback_configuration_description option;
  4. application_snapshot_configuration_description : application_snapshot_configuration_description option;
    (*

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

    *)
  5. environment_property_descriptions : environment_property_descriptions option;
    (*

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

    *)
  6. run_configuration_description : run_configuration_description option;
    (*

    The details about the starting properties for a Managed Service for Apache Flink application.

    *)
  7. application_code_configuration_description : application_code_configuration_description option;
    (*

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

    *)
  8. sql_application_configuration_description : sql_application_configuration_description option;
    (*

    The details about inputs, outputs, and reference data sources for a SQL-based Kinesis Data Analytics application.

    *)
}

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

type nonrec log_stream_ar_n = string
type nonrec cloud_watch_logging_option_description = {
  1. role_ar_n : role_ar_n option;
    (*

    The IAM ARN of the role to use to send application messages.

    Provided for backward compatibility. Applications created with the current API version have an application-level service execution role rather than a resource-level role.

    *)
  2. log_stream_ar_n : log_stream_ar_n;
    (*

    The Amazon Resource Name (ARN) of the CloudWatch log to receive application messages.

    *)
  3. cloud_watch_logging_option_id : id option;
    (*

    The ID of the CloudWatch logging option description.

    *)
}

Describes the Amazon CloudWatch logging option.

type nonrec cloud_watch_logging_option_descriptions = cloud_watch_logging_option_description list
type nonrec application_maintenance_window_start_time = string
type nonrec application_maintenance_window_end_time = string
type nonrec application_maintenance_configuration_description = {
  1. application_maintenance_window_end_time : application_maintenance_window_end_time;
    (*

    The end time for the maintenance window.

    *)
  2. application_maintenance_window_start_time : application_maintenance_window_start_time;
    (*

    The start time for the maintenance window.

    *)
}

The details of the maintenance configuration for the application.

type nonrec conditional_token = string
type nonrec application_mode =
  1. | INTERACTIVE
  2. | STREAMING
type nonrec application_detail = {
  1. application_mode : application_mode option;
    (*

    To create a Managed Service for Apache Flink Studio notebook, you must set the mode to INTERACTIVE. However, for a Managed Service for Apache Flink application, the mode is optional.

    *)
  2. application_version_rolled_back_to : application_version_id option;
    (*

    The version to which you want to roll back the application.

    *)
  3. conditional_token : conditional_token option;
    (*

    A value you use to implement strong concurrency for application updates.

    *)
  4. application_version_create_timestamp : timestamp option;
    (*

    The current timestamp when the application version was created.

    *)
  5. application_version_rolled_back_from : application_version_id option;
    (*

    If you reverted the application using RollbackApplication, the application version when RollbackApplication was called.

    *)
  6. application_version_updated_from : application_version_id option;
    (*

    The previous application version before the latest application update. RollbackApplication reverts the application to this version.

    *)
  7. application_maintenance_configuration_description : application_maintenance_configuration_description option;
    (*

    The details of the maintenance configuration for the application.

    *)
  8. cloud_watch_logging_option_descriptions : cloud_watch_logging_option_descriptions option;
    (*

    Describes the application Amazon CloudWatch logging options.

    *)
  9. application_configuration_description : application_configuration_description option;
    (*

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

    *)
  10. last_update_timestamp : timestamp option;
    (*

    The current timestamp when the application was last updated.

    *)
  11. create_timestamp : timestamp option;
    (*

    The current timestamp when the application was created.

    *)
  12. application_version_id : application_version_id;
    (*

    Provides the current application version. Managed Service for Apache Flink updates the ApplicationVersionId each time you update the application.

    *)
  13. application_status : application_status;
    (*

    The status of the application.

    *)
  14. service_execution_role : role_ar_n option;
    (*

    Specifies the IAM role that the application uses to access external resources.

    *)
  15. runtime_environment : runtime_environment;
    (*

    The runtime environment for the application.

    *)
  16. application_name : application_name;
    (*

    The name of the application.

    *)
  17. application_description : application_description option;
    (*

    The description of the application.

    *)
  18. application_ar_n : resource_ar_n;
    (*

    The ARN of the application.

    *)
}

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

type nonrec operation_id = string
type nonrec update_application_response = {
  1. operation_id : operation_id option;
    (*

    Operation ID for tracking UpdateApplication request

    *)
  2. application_detail : application_detail;
    (*

    Describes application updates.

    *)
}
type nonrec input_lambda_processor_update = {
  1. resource_arn_update : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the new Amazon Lambda function that is used to preprocess the records in the stream.

    To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: Amazon Lambda

    *)
}

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

type nonrec input_processing_configuration_update = {
  1. input_lambda_processor_update : input_lambda_processor_update;
    (*

    Provides update information for an InputLambdaProcessor.

    *)
}

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

type nonrec kinesis_streams_input_update = {
  1. resource_arn_update : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the input Kinesis data stream to read.

    *)
}

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

type nonrec kinesis_firehose_input_update = {
  1. resource_arn_update : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the input delivery stream to read.

    *)
}

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.

type nonrec input_schema_update = {
  1. record_column_updates : record_columns option;
    (*

    A list of RecordColumn objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.

    *)
  2. record_encoding_update : record_encoding option;
    (*

    Specifies the encoding of the records in the streaming source; for example, UTF-8.

    *)
  3. record_format_update : record_format option;
    (*

    Specifies the format of the records on the streaming source.

    *)
}

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

type nonrec input_parallelism_update = {
  1. count_update : input_parallelism_count;
    (*

    The number of in-application streams to create for the specified streaming source.

    *)
}

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

type nonrec input_update = {
  1. input_parallelism_update : input_parallelism_update option;
    (*

    Describes the parallelism updates (the number of in-application streams Kinesis Data Analytics creates for the specific streaming source).

    *)
  2. input_schema_update : input_schema_update option;
    (*

    Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.

    *)
  3. kinesis_firehose_input_update : kinesis_firehose_input_update option;
    (*

    If a Kinesis Data Firehose delivery stream is the streaming source to be updated, provides an updated stream ARN.

    *)
  4. kinesis_streams_input_update : kinesis_streams_input_update option;
    (*

    If a Kinesis data stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN).

    *)
  5. input_processing_configuration_update : input_processing_configuration_update option;
    (*

    Describes updates to an InputProcessingConfiguration.

    *)
  6. name_prefix_update : in_app_stream_name option;
    (*

    The name prefix for in-application streams that Kinesis Data Analytics creates for the specific streaming source.

    *)
  7. input_id : id;
    (*

    The input ID of the application input to be updated.

    *)
}

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

type nonrec input_updates = input_update list
type nonrec kinesis_streams_output_update = {
  1. resource_arn_update : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the Kinesis data stream where you want to write the output.

    *)
}

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.

type nonrec kinesis_firehose_output_update = {
  1. resource_arn_update : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the delivery stream to write to.

    *)
}

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.

type nonrec lambda_output_update = {
  1. resource_arn_update : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the destination Amazon Lambda function.

    To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: Amazon Lambda

    *)
}

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.

type nonrec output_update = {
  1. destination_schema_update : destination_schema option;
    (*

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

    *)
  2. lambda_output_update : lambda_output_update option;
    (*

    Describes an Amazon Lambda function as the destination for the output.

    *)
  3. kinesis_firehose_output_update : kinesis_firehose_output_update option;
    (*

    Describes a Kinesis Data Firehose delivery stream as the destination for the output.

    *)
  4. kinesis_streams_output_update : kinesis_streams_output_update option;
    (*

    Describes a Kinesis data stream as the destination for the output.

    *)
  5. name_update : in_app_stream_name option;
    (*

    If you want to specify a different in-application stream for this output configuration, use this field to specify the new in-application stream name.

    *)
  6. output_id : id;
    (*

    Identifies the specific output configuration that you want to update.

    *)
}

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

type nonrec output_updates = output_update list
type nonrec s3_reference_data_source_update = {
  1. file_key_update : file_key option;
    (*

    The object key name.

    *)
  2. bucket_arn_update : bucket_ar_n option;
    (*

    The Amazon Resource Name (ARN) of the S3 bucket.

    *)
}

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

type nonrec reference_data_source_update = {
  1. reference_schema_update : source_schema option;
    (*

    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.

    *)
  2. s3_reference_data_source_update : s3_reference_data_source_update option;
    (*

    Describes the S3 bucket name, object key name, and IAM role that Kinesis Data Analytics can assume to read the Amazon S3 object on your behalf and populate the in-application reference table.

    *)
  3. table_name_update : in_app_table_name option;
    (*

    The in-application table name that is created by this update.

    *)
  4. reference_id : id;
    (*

    The ID of the reference data source that is being updated. You can use the DescribeApplication operation to get this value.

    *)
}

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.

type nonrec reference_data_source_updates = reference_data_source_update list
type nonrec sql_application_configuration_update = {
  1. reference_data_source_updates : reference_data_source_updates option;
    (*

    The array of ReferenceDataSourceUpdate objects describing the new reference data sources used by the application.

    *)
  2. output_updates : output_updates option;
    (*

    The array of OutputUpdate objects describing the new destination streams used by the application.

    *)
  3. input_updates : input_updates option;
    (*

    The array of InputUpdate objects describing the new input streams used by the application.

    *)
}

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

type nonrec s3_content_location_update = {
  1. object_version_update : object_version option;
    (*

    The new version of the object containing the application code.

    *)
  2. file_key_update : file_key option;
    (*

    The new file key for the object containing the application code.

    *)
  3. bucket_arn_update : bucket_ar_n option;
    (*

    The new Amazon Resource Name (ARN) for the S3 bucket containing the application code.

    *)
}

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

type nonrec code_content_update = {
  1. s3_content_location_update : s3_content_location_update option;
    (*

    Describes an update to the location of code for an application.

    *)
  2. zip_file_content_update : zip_file_content option;
    (*

    Describes an update to the zipped code for an application.

    *)
  3. text_content_update : text_content option;
    (*

    Describes an update to the text code for an application.

    *)
}

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

type nonrec application_code_configuration_update = {
  1. code_content_update : code_content_update option;
    (*

    Describes updates to the code content of an application.

    *)
  2. code_content_type_update : code_content_type option;
    (*

    Describes updates to the code content type.

    *)
}

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.

type nonrec checkpoint_configuration_update = {
  1. min_pause_between_checkpoints_update : min_pause_between_checkpoints option;
    (*

    Describes updates to the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.

    If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a MinPauseBetweenCheckpoints value of 5000, even if this value is set using this API or in application code.

    *)
  2. checkpoint_interval_update : checkpoint_interval option;
    (*

    Describes updates to the interval in milliseconds between checkpoint operations.

    If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointInterval value of 60000, even if this value is set to another value using this API or in application code.

    *)
  3. checkpointing_enabled_update : boolean_object option;
    (*

    Describes updates to whether checkpointing is enabled for an application.

    If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointingEnabled value of true, even if this value is set to another value using this API or in application code.

    *)
  4. configuration_type_update : configuration_type option;
    (*

    Describes updates to whether the application uses the default checkpointing behavior of Managed Service for Apache Flink. You must set this property to CUSTOM in order to set the CheckpointingEnabled, CheckpointInterval, or MinPauseBetweenCheckpoints parameters.

    If this value is set to DEFAULT, the application will use the following values, even if they are set to other values using APIs or application code:

    • CheckpointingEnabled: true
    • CheckpointInterval: 60000
    • MinPauseBetweenCheckpoints: 5000
    *)
}

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

type nonrec monitoring_configuration_update = {
  1. log_level_update : log_level option;
    (*

    Describes updates to the verbosity of the CloudWatch Logs for an application.

    *)
  2. metrics_level_update : metrics_level option;
    (*

    Describes updates to the granularity of the CloudWatch Logs for an application. The Parallelism level is not recommended for applications with a Parallelism over 64 due to excessive costs.

    *)
  3. configuration_type_update : configuration_type option;
    (*

    Describes updates to whether to use the default CloudWatch logging configuration for an application. You must set this property to CUSTOM in order to set the LogLevel or MetricsLevel parameters.

    *)
}

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

type nonrec parallelism_configuration_update = {
  1. auto_scaling_enabled_update : boolean_object option;
    (*

    Describes updates to whether the Managed Service for Apache Flink service can increase the parallelism of a Managed Service for Apache Flink application in response to increased throughput.

    *)
  2. parallelism_per_kpu_update : parallelism_per_kp_u option;
    (*

    Describes updates to the number of parallel tasks an application can perform per Kinesis Processing Unit (KPU) used by the application.

    *)
  3. parallelism_update : parallelism option;
    (*

    Describes updates to the initial number of parallel tasks an application can perform. If AutoScalingEnabled is set to True, then Managed Service for Apache Flink can increase the CurrentParallelism value in response to application load. The service can increase CurrentParallelism up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service will reduce CurrentParallelism down to the Parallelism setting.

    *)
  4. configuration_type_update : configuration_type option;
    (*

    Describes updates to whether the application uses the default parallelism for the Managed Service for Apache Flink service, or if a custom parallelism is used. You must set this property to CUSTOM in order to change your application's AutoScalingEnabled, Parallelism, or ParallelismPerKPU properties.

    *)
}

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

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

type nonrec environment_property_updates = {
  1. property_groups : property_groups;
    (*

    Describes updates to the execution property groups.

    *)
}

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

type nonrec application_snapshot_configuration_update = {
  1. snapshots_enabled_update : boolean_object;
    (*

    Describes updates to whether snapshots are enabled for an application.

    *)
}

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

type nonrec application_system_rollback_configuration_update = {
  1. rollback_enabled_update : boolean_object;
    (*

    Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application

    *)
}

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

type nonrec application_configuration_update = {
  1. zeppelin_application_configuration_update : zeppelin_application_configuration_update option;
    (*

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

    *)
  2. vpc_configuration_updates : vpc_configuration_updates option;
    (*

    Updates to the array of descriptions of VPC configurations available to the application.

    *)
  3. application_system_rollback_configuration_update : application_system_rollback_configuration_update option;
  4. application_snapshot_configuration_update : application_snapshot_configuration_update option;
    (*

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

    *)
  5. environment_property_updates : environment_property_updates option;
    (*

    Describes updates to the environment properties for a Managed Service for Apache Flink application.

    *)
  6. application_code_configuration_update : application_code_configuration_update option;
    (*

    Describes updates to an application's code configuration.

    *)
  7. sql_application_configuration_update : sql_application_configuration_update option;
    (*

    Describes updates to a SQL-based Kinesis Data Analytics application's configuration.

    *)
}

Describes updates to an application's configuration.

type nonrec run_configuration_update = {
  1. application_restore_configuration : application_restore_configuration option;
    (*

    Describes updates to the restore behavior of a restarting application.

    *)
}

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

type nonrec cloud_watch_logging_option_update = {
  1. log_stream_arn_update : log_stream_ar_n option;
    (*

    The Amazon Resource Name (ARN) of the CloudWatch log to receive application messages.

    *)
  2. cloud_watch_logging_option_id : id;
    (*

    The ID of the CloudWatch logging option to update

    *)
}

Describes the Amazon CloudWatch logging option updates.

type nonrec cloud_watch_logging_option_updates = cloud_watch_logging_option_update list
type nonrec update_application_request = {
  1. runtime_environment_update : runtime_environment option;
    (*

    Updates the Managed Service for Apache Flink runtime environment used to run your code. To avoid issues you must:

    • Ensure your new jar and dependencies are compatible with the new runtime selected.
    • Ensure your new code's state is compatible with the snapshot from which your application will start
    *)
  2. conditional_token : conditional_token option;
    (*

    A value you use to implement strong concurrency for application updates. You must provide the CurrentApplicationVersionId or the ConditionalToken. You get the application's current ConditionalToken using DescribeApplication. For better concurrency support, use the ConditionalToken parameter instead of CurrentApplicationVersionId.

    *)
  3. cloud_watch_logging_option_updates : cloud_watch_logging_option_updates option;
    (*

    Describes application Amazon CloudWatch logging option updates. You can only update existing CloudWatch logging options with this action. To add a new CloudWatch logging option, use AddApplicationCloudWatchLoggingOption.

    *)
  4. run_configuration_update : run_configuration_update option;
    (*

    Describes updates to the application's starting parameters.

    *)
  5. service_execution_role_update : role_ar_n option;
    (*

    Describes updates to the service execution role.

    *)
  6. application_configuration_update : application_configuration_update option;
    (*

    Describes application configuration updates.

    *)
  7. current_application_version_id : application_version_id option;
    (*

    The current application version ID. You must provide the CurrentApplicationVersionId or the ConditionalToken.You can retrieve the application version ID using DescribeApplication. For better concurrency support, use the ConditionalToken parameter instead of CurrentApplicationVersionId.

    *)
  8. application_name : application_name;
    (*

    The name of the application to update.

    *)
}
type nonrec update_application_maintenance_configuration_response = {
  1. application_maintenance_configuration_description : application_maintenance_configuration_description option;
    (*

    The application maintenance configuration description after the update.

    *)
  2. application_ar_n : resource_ar_n option;
    (*

    The Amazon Resource Name (ARN) of the application.

    *)
}
type nonrec application_maintenance_configuration_update = {
  1. application_maintenance_window_start_time_update : application_maintenance_window_start_time;
    (*

    The updated start time for the maintenance window.

    *)
}

Describes the updated maintenance configuration for the application.

type nonrec update_application_maintenance_configuration_request = {
  1. application_maintenance_configuration_update : application_maintenance_configuration_update;
    (*

    Describes the application maintenance configuration update.

    *)
  2. application_name : application_name;
    (*

    The name of the application for which you want to update the maintenance configuration.

    *)
}
type nonrec error_message = string
type nonrec unsupported_operation_exception = {
  1. message : error_message option;
}

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

type nonrec resource_not_found_exception = {
  1. message : error_message option;
}

Specified application can't be found.

type nonrec resource_in_use_exception = {
  1. message : error_message option;
}

The application is not available for this operation.

type nonrec invalid_argument_exception = {
  1. message : error_message option;
}

The specified input parameter value is not valid.

type nonrec concurrent_modification_exception = {
  1. message : error_message option;
}

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.

type nonrec limit_exceeded_exception = {
  1. message : error_message option;
}

The number of allowed resources has been exceeded.

type nonrec invalid_request_exception = {
  1. message : error_message option;
}

The request JSON is not valid for the operation.

type nonrec invalid_application_configuration_exception = {
  1. message : error_message option;
}

The user-provided application configuration is not valid.

type nonrec code_validation_exception = {
  1. message : error_message option;
}

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

type nonrec untag_resource_response = unit
type nonrec kinesis_analytics_ar_n = string
type nonrec tag_key = string
type nonrec tag_keys = tag_key list
type nonrec untag_resource_request = {
  1. tag_keys : tag_keys;
    (*

    A list of keys of tags to remove from the specified application.

    *)
  2. resource_ar_n : kinesis_analytics_ar_n;
    (*

    The ARN of the Managed Service for Apache Flink application from which to remove the tags.

    *)
}
type nonrec too_many_tags_exception = {
  1. message : error_message option;
}

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.

type nonrec raw_input_record = string
type nonrec raw_input_records = raw_input_record list
type nonrec processed_input_record = string
type nonrec processed_input_records = processed_input_record list
type nonrec unable_to_detect_schema_exception = {
  1. processed_input_records : processed_input_records option;
    (*

    Stream data that was modified by the processor specified in the InputProcessingConfiguration parameter.

    *)
  2. raw_input_records : raw_input_records option;
    (*

    Raw stream data that was sampled to infer the schema.

    *)
  3. message : error_message option;
}

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

type nonrec tag_value = string
type nonrec tag = {
  1. value : tag_value option;
    (*

    The value of the key-value tag. The value is optional.

    *)
  2. key : tag_key;
    (*

    The key of the key-value tag.

    *)
}

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.

type nonrec tags = tag list
type nonrec tag_resource_response = unit
type nonrec tag_resource_request = {
  1. tags : tags;
    (*

    The key-value tags to assign to the application.

    *)
  2. resource_ar_n : kinesis_analytics_ar_n;
    (*

    The ARN of the application to assign the tags.

    *)
}
type nonrec stop_application_response = {
  1. operation_id : operation_id option;
    (*

    Operation ID for tracking StopApplication request

    *)
}
type nonrec stop_application_request = {
  1. force : boolean_object option;
    (*

    Set to true to force the application to stop. If you set Force to true, Managed Service for Apache Flink stops the application without taking a snapshot.

    Force-stopping your application may lead to data loss or duplication. To prevent data loss or duplicate processing of data during application restarts, we recommend you to take frequent snapshots of your application.

    You can only force stop a Managed Service for Apache Flink application. You can't force stop a SQL-based Kinesis Data Analytics application.

    The application must be in the STARTING, UPDATING, STOPPING, AUTOSCALING, or RUNNING status.

    *)
  2. application_name : application_name;
    (*

    The name of the running application to stop.

    *)
}
type nonrec start_application_response = {
  1. operation_id : operation_id option;
    (*

    Operation ID for tracking StartApplication request

    *)
}
type nonrec sql_run_configuration = {
  1. input_starting_position_configuration : input_starting_position_configuration;
    (*

    The point at which you want the application to start processing records from the streaming source.

    *)
  2. input_id : id;
    (*

    The input source ID. You can get this ID by calling the DescribeApplication operation.

    *)
}

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

type nonrec sql_run_configurations = sql_run_configuration list
type nonrec run_configuration = {
  1. application_restore_configuration : application_restore_configuration option;
    (*

    Describes the restore behavior of a restarting application.

    *)
  2. sql_run_configurations : sql_run_configurations option;
    (*

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

    *)
}

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

type nonrec start_application_request = {
  1. run_configuration : run_configuration option;
    (*

    Identifies the run configuration (start parameters) of a Managed Service for Apache Flink application.

    *)
  2. application_name : application_name;
    (*

    The name of the application.

    *)
}
type nonrec input_lambda_processor = {
  1. resource_ar_n : resource_ar_n;
    (*

    The ARN of the Amazon Lambda function that operates on records in the stream.

    To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: Amazon Lambda

    *)
}

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.

type nonrec input_processing_configuration = {
  1. input_lambda_processor : input_lambda_processor;
    (*

    The InputLambdaProcessor that is used to preprocess the records in the stream before being processed by your application code.

    *)
}

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.

type nonrec kinesis_streams_input = {
  1. resource_ar_n : resource_ar_n;
    (*

    The ARN of the input Kinesis data stream to read.

    *)
}

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

type nonrec kinesis_firehose_input = {
  1. resource_ar_n : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the delivery stream.

    *)
}

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

type nonrec input = {
  1. input_schema : source_schema;
    (*

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

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

    *)
  2. input_parallelism : input_parallelism option;
    (*

    Describes the number of in-application streams to create.

    *)
  3. kinesis_firehose_input : kinesis_firehose_input option;
    (*

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

    *)
  4. kinesis_streams_input : kinesis_streams_input option;
    (*

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

    *)
  5. input_processing_configuration : input_processing_configuration option;
    (*

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

    *)
  6. name_prefix : in_app_stream_name;
    (*

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

    *)
}

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.

type nonrec inputs = input list
type nonrec kinesis_streams_output = {
  1. resource_ar_n : resource_ar_n;
    (*

    The ARN of the destination Kinesis data stream to write to.

    *)
}

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

type nonrec kinesis_firehose_output = {
  1. resource_ar_n : resource_ar_n;
    (*

    The ARN of the destination delivery stream to write to.

    *)
}

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.

type nonrec lambda_output = {
  1. resource_ar_n : resource_ar_n;
    (*

    The Amazon Resource Name (ARN) of the destination Lambda function to write to.

    To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: Amazon Lambda

    *)
}

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.

type nonrec output = {
  1. destination_schema : destination_schema;
    (*

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

    *)
  2. lambda_output : lambda_output option;
    (*

    Identifies an Amazon Lambda function as the destination.

    *)
  3. kinesis_firehose_output : kinesis_firehose_output option;
    (*

    Identifies a Kinesis Data Firehose delivery stream as the destination.

    *)
  4. kinesis_streams_output : kinesis_streams_output option;
    (*

    Identifies a Kinesis data stream as the destination.

    *)
  5. name : in_app_stream_name;
    (*

    The name of the in-application stream.

    *)
}

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.

type nonrec outputs = output list
type nonrec s3_reference_data_source = {
  1. file_key : file_key option;
    (*

    The object key name containing the reference data.

    *)
  2. bucket_ar_n : bucket_ar_n option;
    (*

    The Amazon Resource Name (ARN) of the S3 bucket.

    *)
}

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.

type nonrec reference_data_source = {
  1. reference_schema : source_schema;
    (*

    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.

    *)
  2. s3_reference_data_source : s3_reference_data_source option;
    (*

    Identifies the 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.

    *)
  3. table_name : in_app_table_name;
    (*

    The name of the in-application table to create.

    *)
}

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.

type nonrec reference_data_sources = reference_data_source list
type nonrec sql_application_configuration = {
  1. reference_data_sources : reference_data_sources option;
    (*

    The array of ReferenceDataSource objects describing the reference data sources used by the application.

    *)
  2. outputs : outputs option;
    (*

    The array of Output objects describing the destination streams used by the application.

    *)
  3. inputs : inputs option;
    (*

    The array of Input objects describing the input streams used by the application.

    *)
}

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

type nonrec snapshot_status =
  1. | FAILED
  2. | DELETING
  3. | READY
  4. | CREATING
type nonrec snapshot_details = {
  1. runtime_environment : runtime_environment option;
    (*

    The Flink Runtime for the application snapshot.

    *)
  2. snapshot_creation_timestamp : timestamp option;
    (*

    The timestamp of the application snapshot.

    *)
  3. application_version_id : application_version_id;
    (*

    The current application version ID when the snapshot was created.

    *)
  4. snapshot_status : snapshot_status;
    (*

    The status of the application snapshot.

    *)
  5. snapshot_name : snapshot_name;
    (*

    The identifier for the application snapshot.

    *)
}

Provides details about a snapshot of application state.

type nonrec snapshot_summaries = snapshot_details list
type nonrec session_expiration_duration_in_seconds = int
type nonrec service_unavailable_exception = {
  1. message : error_message option;
}

The service cannot complete the request.

type nonrec s3_configuration = {
  1. file_key : file_key;
    (*

    The name of the object that contains the data.

    *)
  2. bucket_ar_n : bucket_ar_n;
    (*

    The ARN of the S3 bucket that contains the data.

    *)
}

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.

type nonrec rollback_application_response = {
  1. operation_id : operation_id option;
    (*

    Operation ID for tracking RollbackApplication request

    *)
  2. application_detail : application_detail;
}
type nonrec rollback_application_request = {
  1. current_application_version_id : application_version_id;
    (*

    The current application version ID. You can retrieve the application version ID using DescribeApplication.

    *)
  2. application_name : application_name;
    (*

    The name of the application.

    *)
}
type nonrec resource_provisioned_throughput_exceeded_exception = {
  1. message : error_message option;
}

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.

type nonrec parsed_input_record_field = string
type nonrec parsed_input_record = parsed_input_record_field list
type nonrec parsed_input_records = parsed_input_record list
type nonrec parallelism_configuration = {
  1. auto_scaling_enabled : boolean_object option;
    (*

    Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.

    *)
  2. parallelism_per_kp_u : parallelism_per_kp_u option;
    (*

    Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application. For more information about KPUs, see Amazon Managed Service for Apache Flink Pricing.

    *)
  3. parallelism : parallelism option;
    (*

    Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, Managed Service for Apache Flink increases the CurrentParallelism value in response to application load. The service can increase the CurrentParallelism value up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.

    *)
  4. configuration_type : configuration_type;
    (*

    Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service. You must set this property to CUSTOM in order to change your application's AutoScalingEnabled, Parallelism, or ParallelismPerKPU properties.

    *)
}

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.

type nonrec operation_status =
  1. | FAILED
  2. | SUCCESSFUL
  3. | CANCELLED
  4. | IN_PROGRESS

Status of the operation performed on an application

type nonrec error_string = string
type nonrec error_info = {
  1. error_string : error_string option;
}

Provides a description of the operation failure error

type nonrec operation_failure_details = {
  1. error_info : error_info option;
  2. rollback_operation_id : operation_id option;
    (*

    Provides the operation ID of a system-rollback operation executed due to failure in the current operation

    *)
}

Provides a description of the operation failure

type nonrec operation = string
type nonrec next_token = string
type nonrec monitoring_configuration = {
  1. log_level : log_level option;
    (*

    Describes the verbosity of the CloudWatch Logs for an application.

    *)
  2. metrics_level : metrics_level option;
    (*

    Describes the granularity of the CloudWatch Logs for an application. The Parallelism level is not recommended for applications with a Parallelism over 64 due to excessive costs.

    *)
  3. configuration_type : configuration_type;
    (*

    Describes whether to use the default CloudWatch logging configuration for an application. You must set this property to CUSTOM in order to set the LogLevel or MetricsLevel parameters.

    *)
}

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

type nonrec list_tags_for_resource_response = {
  1. tags : tags option;
    (*

    The key-value tags assigned to the application.

    *)
}
type nonrec list_tags_for_resource_request = {
  1. resource_ar_n : kinesis_analytics_ar_n;
    (*

    The ARN of the application for which to retrieve tags.

    *)
}
type nonrec list_snapshots_input_limit = int
type nonrec application_summary = {
  1. application_mode : application_mode option;
    (*

    For a Managed Service for Apache Flink application, the mode is STREAMING. For a Managed Service for Apache Flink Studio notebook, it is INTERACTIVE.

    *)
  2. runtime_environment : runtime_environment;
    (*

    The runtime environment for the application.

    *)
  3. application_version_id : application_version_id;
    (*

    Provides the current application version.

    *)
  4. application_status : application_status;
    (*

    The status of the application.

    *)
  5. application_ar_n : resource_ar_n;
    (*

    The ARN of the application.

    *)
  6. application_name : application_name;
    (*

    The name of the application.

    *)
}

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

type nonrec application_summaries = application_summary list
type nonrec list_applications_response = {
  1. next_token : application_name option;
    (*

    The pagination token for the next set of results, or null if there are no additional results. Pass this token into a subsequent command to retrieve the next set of items For more information about pagination, see Using the Amazon Command Line Interface's Pagination Options.

    *)
  2. application_summaries : application_summaries;
    (*

    A list of ApplicationSummary objects.

    *)
}
type nonrec list_applications_input_limit = int
type nonrec list_applications_request = {
  1. next_token : application_name option;
    (*

    If a previous command returned a pagination token, pass it into this value to retrieve the next set of results. For more information about pagination, see Using the Amazon Command Line Interface's Pagination Options.

    *)
  2. limit : list_applications_input_limit option;
    (*

    The maximum number of applications to list.

    *)
}
type nonrec application_version_summary = {
  1. application_status : application_status;
    (*

    The status of the application.

    *)
  2. application_version_id : application_version_id;
    (*

    The ID of the application version. Managed Service for Apache Flink updates the ApplicationVersionId each time you update the application.

    *)
}

The summary of the application version.

type nonrec application_version_summaries = application_version_summary list
type nonrec list_application_versions_response = {
  1. next_token : next_token option;
    (*

    The pagination token for the next set of results, or null if there are no additional results. To retrieve the next set of items, pass this token into a subsequent invocation of this operation. For more information about pagination, see Using the Amazon Command Line Interface's Pagination Options.

    *)
  2. application_version_summaries : application_version_summaries option;
    (*

    A list of the application versions and the associated configuration summaries. The list includes application versions that were rolled back.

    To get the complete description of a specific application version, invoke the DescribeApplicationVersion operation.

    *)
}
type nonrec list_application_versions_input_limit = int
type nonrec list_application_versions_request = {
  1. next_token : next_token option;
    (*

    If a previous invocation of this operation returned a pagination token, pass it into this value to retrieve the next set of results. For more information about pagination, see Using the Amazon Command Line Interface's Pagination Options.

    *)
  2. limit : list_application_versions_input_limit option;
    (*

    The maximum number of versions to list in this invocation of the operation.

    *)
  3. application_name : application_name;
    (*

    The name of the application for which you want to list all versions.

    *)
}
type nonrec list_application_snapshots_response = {
  1. next_token : next_token option;
    (*

    The token for the next set of results, or null if there are no additional results.

    *)
  2. snapshot_summaries : snapshot_summaries option;
    (*

    A collection of objects containing information about the application snapshots.

    *)
}
type nonrec list_application_snapshots_request = {
  1. next_token : next_token option;
    (*

    Use this parameter if you receive a NextToken response in a previous request that indicates that there is more output available. Set it to the value of the previous call's NextToken response to indicate where the output should continue from.

    *)
  2. limit : list_snapshots_input_limit option;
    (*

    The maximum number of application snapshots to list.

    *)
  3. application_name : application_name;
    (*

    The name of an existing application.

    *)
}
type nonrec application_operation_info = {
  1. operation_status : operation_status option;
  2. end_time : timestamp option;
    (*

    The timestamp at which the operation finished for the application

    *)
  3. start_time : timestamp option;
    (*

    The timestamp at which the operation was created

    *)
  4. operation_id : operation_id option;
  5. operation : operation option;
}

Provides a description of the operation, such as the type and status of operation

type nonrec application_operation_info_list = application_operation_info list
type nonrec list_application_operations_response = {
  1. next_token : next_token option;
  2. application_operation_info_list : application_operation_info_list option;
}

Response with the list of operations for an application

type nonrec list_application_operations_input_limit = int
type nonrec list_application_operations_request = {
  1. operation_status : operation_status option;
  2. operation : operation option;
  3. next_token : next_token option;
  4. limit : list_application_operations_input_limit option;
  5. application_name : application_name;
}

Request to list operations performed on an application

type nonrec discover_input_schema_response = {
  1. raw_input_records : raw_input_records option;
    (*

    The raw stream data that was sampled to infer the schema.

    *)
  2. processed_input_records : processed_input_records option;
    (*

    The stream data that was modified by the processor specified in the InputProcessingConfiguration parameter.

    *)
  3. parsed_input_records : parsed_input_records option;
    (*

    An array of elements, where each element corresponds to a row in a stream record (a stream record can have more than one row).

    *)
  4. input_schema : source_schema option;
    (*

    The schema inferred from the streaming source. It identifies the format of the data in the streaming source and how each data element maps to corresponding columns in the in-application stream that you can create.

    *)
}
type nonrec discover_input_schema_request = {
  1. input_processing_configuration : input_processing_configuration option;
    (*

    The InputProcessingConfiguration to use to preprocess the records before discovering the schema of the records.

    *)
  2. s3_configuration : s3_configuration option;
    (*

    Specify this parameter to discover a schema from data in an Amazon S3 object.

    *)
  3. input_starting_position_configuration : input_starting_position_configuration option;
    (*

    The point at which you want Kinesis Data Analytics to start reading records from the specified streaming source for discovery purposes.

    *)
  4. service_execution_role : role_ar_n;
    (*

    The ARN of the role that is used to access the streaming source.

    *)
  5. resource_ar_n : resource_ar_n option;
    (*

    The Amazon Resource Name (ARN) of the streaming source.

    *)
}
type nonrec describe_application_version_response = {
  1. application_version_detail : application_detail option;
}
type nonrec describe_application_version_request = {
  1. application_version_id : application_version_id;
    (*

    The ID of the application version for which you want to get the description.

    *)
  2. application_name : application_name;
    (*

    The name of the application for which you want to get the version description.

    *)
}
type nonrec describe_application_snapshot_response = {
  1. snapshot_details : snapshot_details;
    (*

    An object containing information about the application snapshot.

    *)
}
type nonrec describe_application_snapshot_request = {
  1. snapshot_name : snapshot_name;
    (*

    The identifier of an application snapshot. You can retrieve this value using .

    *)
  2. application_name : application_name;
    (*

    The name of an existing application.

    *)
}
type nonrec application_version_change_details = {
  1. application_version_updated_to : application_version_id;
    (*

    The operation execution resulted in the transition to the following version of the application

    *)
  2. application_version_updated_from : application_version_id;
    (*

    The operation was performed on this version of the application

    *)
}

Contains information about the application version changes due to an operation

type nonrec application_operation_info_details = {
  1. operation_failure_details : operation_failure_details option;
  2. application_version_change_details : application_version_change_details option;
  3. operation_status : operation_status;
  4. end_time : timestamp;
    (*

    The timestamp at which the operation finished for the application

    *)
  5. start_time : timestamp;
    (*

    The timestamp at which the operation was created

    *)
  6. operation : operation;
}

Provides a description of the operation, such as the operation-type and status

type nonrec describe_application_operation_response = {
  1. application_operation_info_details : application_operation_info_details option;
}

Provides details of the operation corresponding to the operation-ID on a Managed Service for Apache Flink application

type nonrec describe_application_operation_request = {
  1. operation_id : operation_id;
  2. application_name : application_name;
}

Request for information about a specific operation performed on a Managed Service for Apache Flink application

type nonrec describe_application_response = {
  1. application_detail : application_detail;
    (*

    Provides a description of the application, such as the application's Amazon Resource Name (ARN), status, and latest version.

    *)
}
type nonrec describe_application_request = {
  1. include_additional_details : boolean_object option;
    (*

    Displays verbose information about a Managed Service for Apache Flink application, including the application's job plan.

    *)
  2. application_name : application_name;
    (*

    The name of the application.

    *)
}
type nonrec delete_application_vpc_configuration_response = {
  1. operation_id : operation_id option;
    (*

    Operation ID for tracking DeleteApplicationVpcConfiguration request

    *)
  2. application_version_id : application_version_id option;
    (*

    The updated version ID of the application.

    *)
  3. application_ar_n : resource_ar_n option;
    (*

    The ARN of the Managed Service for Apache Flink application.

    *)
}
type nonrec delete_application_vpc_configuration_request = {
  1. conditional_token : conditional_token option;
    (*

    A value you use to implement strong concurrency for application updates. You must provide the CurrentApplicationVersionId or the ConditionalToken. You get the application's current ConditionalToken using DescribeApplication. For better concurrency support, use the ConditionalToken parameter instead of CurrentApplicationVersionId.

    *)
  2. vpc_configuration_id : id;
    (*

    The ID of the VPC configuration to delete.

    *)
  3. current_application_version_id : application_version_id option;
    (*

    The current application version ID. You must provide the CurrentApplicationVersionId or the ConditionalToken. You can retrieve the application version ID using DescribeApplication. For better concurrency support, use the ConditionalToken parameter instead of CurrentApplicationVersionId.

    *)
  4. application_name : application_name;
    (*

    The name of an existing application.

    *)
}
type nonrec delete_application_snapshot_response = unit
type nonrec delete_application_snapshot_request = {
  1. snapshot_creation_timestamp : timestamp;
    (*

    The creation timestamp of the application snapshot to delete. You can retrieve this value using or .

    *)
  2. snapshot_name : snapshot_name;
    (*

    The identifier for the snapshot delete.

    *)
  3. application_name : application_name;
    (*

    The name of an existing application.

    *)
}
type nonrec delete_application_reference_data_source_response = {
  1. application_version_id : application_version_id option;
    (*

    The updated version ID of the application.

    *)
  2. application_ar_n : resource_ar_n option;
    (*

    The application Amazon Resource Name (ARN).

    *)
}
type nonrec delete_application_reference_data_source_request = {
  1. reference_id : id;
    (*

    The ID of the reference data source. When you add a reference data source to your application using the AddApplicationReferenceDataSource, Kinesis Data Analytics assigns an ID. You can use the DescribeApplication operation to get the reference ID.

    *)
  2. current_application_version_id : application_version_id;
    (*

    The current application version. You can use the DescribeApplication operation to get the current application version. If the version specified is not the current version, the ConcurrentModificationException is returned.

    *)
  3. application_name : application_name;
    (*

    The name of an existing application.

    *)
}
type nonrec delete_application_output_response = {
  1. application_version_id : application_version_id option;
    (*

    The current application version ID.

    *)
  2. application_ar_n : resource_ar_n option;
    (*

    The application Amazon Resource Name (ARN).

    *)
}
type nonrec delete_application_output_request = {
  1. output_id : id;
    (*

    The ID of the configuration to delete. Each output configuration that is added to the application (either when the application is created or later) using the AddApplicationOutput operation has a unique ID. You need to provide the ID to uniquely identify the output configuration that you want to delete from the application configuration. You can use the DescribeApplication operation to get the specific OutputId.

    *)
  2. current_application_version_id : application_version_id;
    (*

    The application version. You can use the DescribeApplication operation to get the current application version. If the version specified is not the current version, the ConcurrentModificationException is returned.

    *)
  3. application_name : application_name;
    (*

    The application name.

    *)
}
type nonrec delete_application_input_processing_configuration_response = {
  1. application_version_id : application_version_id option;
    (*

    The current application version ID.

    *)
  2. application_ar_n : resource_ar_n option;
    (*

    The Amazon Resource Name (ARN) of the application.

    *)
}
type nonrec delete_application_input_processing_configuration_request = {
  1. input_id : id;
    (*

    The ID of the input configuration from which to delete the input processing configuration. You can get a list of the input IDs for an application by using the DescribeApplication operation.

    *)
  2. current_application_version_id : application_version_id;
    (*

    The application version. You can use the DescribeApplication operation to get the current application version. If the version specified is not the current version, the ConcurrentModificationException is returned.

    *)
  3. application_name : application_name;
    (*

    The name of the application.

    *)
}
type nonrec delete_application_cloud_watch_logging_option_response = {
  1. operation_id : operation_id option;
    (*

    Operation ID for tracking DeleteApplicationCloudWatchLoggingOption request

    *)
  2. cloud_watch_logging_option_descriptions : cloud_watch_logging_option_descriptions option;
    (*

    The descriptions of the remaining CloudWatch logging options for the application.

    *)
  3. application_version_id : application_version_id option;
    (*

    The version ID of the application. Kinesis Data Analytics updates the ApplicationVersionId each time you change the CloudWatch logging options.

    *)
  4. application_ar_n : resource_ar_n option;
    (*

    The application's Amazon Resource Name (ARN).

    *)
}
type nonrec delete_application_cloud_watch_logging_option_request = {
  1. conditional_token : conditional_token option;
    (*

    A value you use to implement strong concurrency for application updates. You must provide the CurrentApplicationVersionId or the ConditionalToken. You get the application's current ConditionalToken using DescribeApplication. For better concurrency support, use the ConditionalToken parameter instead of CurrentApplicationVersionId.

    *)
  2. cloud_watch_logging_option_id : id;
    (*

    The CloudWatchLoggingOptionId of the Amazon CloudWatch logging option to delete. You can get the CloudWatchLoggingOptionId by using the DescribeApplication operation.

    *)
  3. current_application_version_id : application_version_id option;
    (*

    The version ID of the application. You must provide the CurrentApplicationVersionId or the ConditionalToken. You can retrieve the application version ID using DescribeApplication. For better concurrency support, use the ConditionalToken parameter instead of CurrentApplicationVersionId.

    *)
  4. application_name : application_name;
    (*

    The application name.

    *)
}
type nonrec delete_application_response = unit
type nonrec delete_application_request = {
  1. create_timestamp : timestamp;
    (*

    Use the DescribeApplication operation to get this value.

    *)
  2. application_name : application_name;
    (*

    The name of the application to delete.

    *)
}
type nonrec create_application_snapshot_response = unit
type nonrec create_application_snapshot_request = {
  1. snapshot_name : snapshot_name;
    (*

    An identifier for the application snapshot.

    *)
  2. application_name : application_name;
    (*

    The name of an existing application

    *)
}
type nonrec authorized_url = string
type nonrec create_application_presigned_url_response = {
  1. authorized_url : authorized_url option;
    (*

    The URL of the extension.

    *)
}
type nonrec create_application_presigned_url_request = {
  1. session_expiration_duration_in_seconds : session_expiration_duration_in_seconds option;
    (*

    The duration in seconds for which the returned URL will be valid.

    *)
  2. url_type : url_type;
    (*

    The type of the extension for which to create and return a URL. Currently, the only valid extension URL type is FLINK_DASHBOARD_URL.

    *)
  3. application_name : application_name;
    (*

    The name of the application.

    *)
}
type nonrec create_application_response = {
  1. application_detail : application_detail;
    (*

    In response to your CreateApplication request, Managed Service for Apache Flink returns a response with details of the application it created.

    *)
}
type nonrec checkpoint_configuration = {
  1. min_pause_between_checkpoints : min_pause_between_checkpoints option;
    (*

    Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start. If a checkpoint operation takes longer than the CheckpointInterval, the application otherwise performs continual checkpoint operations. For more information, see Tuning Checkpointing in the Apache Flink Documentation.

    If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a MinPauseBetweenCheckpoints value of 5000, even if this value is set using this API or in application code.

    *)
  2. checkpoint_interval : checkpoint_interval option;
    (*

    Describes the interval in milliseconds between checkpoint operations.

    If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointInterval value of 60000, even if this value is set to another value using this API or in application code.

    *)
  3. checkpointing_enabled : boolean_object option;
    (*

    Describes whether checkpointing is enabled for a Managed Service for Apache Flink application.

    If CheckpointConfiguration.ConfigurationType is DEFAULT, the application will use a CheckpointingEnabled value of true, even if this value is set to another value using this API or in application code.

    *)
  4. configuration_type : configuration_type;
    (*

    Describes whether the application uses Managed Service for Apache Flink' default checkpointing behavior. You must set this property to CUSTOM in order to set the CheckpointingEnabled, CheckpointInterval, or MinPauseBetweenCheckpoints parameters.

    If this value is set to DEFAULT, the application will use the following values, even if they are set to other values using APIs or application code:

    • CheckpointingEnabled: true
    • CheckpointInterval: 60000
    • MinPauseBetweenCheckpoints: 5000
    *)
}

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

type nonrec environment_properties = {
  1. property_groups : property_groups;
    (*

    Describes the execution property groups.

    *)
}

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

type nonrec code_content = {
  1. s3_content_location : s3_content_location option;
    (*

    Information about the Amazon S3 bucket that contains the application code.

    *)
  2. zip_file_content : zip_file_content option;
    (*

    The zip-format code for a Managed Service for Apache Flink application.

    *)
  3. text_content : text_content option;
    (*

    The text-format code for a Managed Service for Apache Flink application.

    *)
}

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

type nonrec application_code_configuration = {
  1. code_content_type : code_content_type;
    (*

    Specifies whether the code content is in text or zip format.

    *)
  2. code_content : code_content option;
    (*

    The location and type of the application code.

    *)
}

Describes code configuration for an application.

type nonrec application_snapshot_configuration = {
  1. snapshots_enabled : boolean_object;
    (*

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

    *)
}

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

type nonrec application_system_rollback_configuration = {
  1. rollback_enabled : boolean_object;
    (*

    Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application

    *)
}

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

type nonrec application_configuration = {
  1. zeppelin_application_configuration : zeppelin_application_configuration option;
    (*

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

    *)
  2. vpc_configurations : vpc_configurations option;
    (*

    The array of descriptions of VPC configurations available to the application.

    *)
  3. application_system_rollback_configuration : application_system_rollback_configuration option;
  4. application_snapshot_configuration : application_snapshot_configuration option;
    (*

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

    *)
  5. application_code_configuration : application_code_configuration option;
    (*

    The code location and type parameters for a Managed Service for Apache Flink application.

    *)
  6. environment_properties : environment_properties option;
    (*

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

    *)
  7. sql_application_configuration : sql_application_configuration option;
    (*

    The creation and update parameters for a SQL-based Kinesis Data Analytics application.

    *)
}

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

type nonrec cloud_watch_logging_option = {
  1. log_stream_ar_n : log_stream_ar_n;
    (*

    The ARN of the CloudWatch log to receive application messages.

    *)
}

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

type nonrec cloud_watch_logging_options = cloud_watch_logging_option list
type nonrec create_application_request = {
  1. application_mode : application_mode option;
    (*

    Use the STREAMING mode to create a Managed Service for Apache Flink application. To create a Managed Service for Apache Flink Studio notebook, use the INTERACTIVE mode.

    *)
  2. tags : tags option;
    (*

    A list of one or more tags to assign to the application. A tag is a key-value pair that identifies an application. Note that the maximum number of application tags includes system tags. The maximum number of user-defined application tags is 50. For more information, see Using Tagging.

    *)
  3. cloud_watch_logging_options : cloud_watch_logging_options option;
    (*

    Use this parameter to configure an Amazon CloudWatch log stream to monitor application configuration errors.

    *)
  4. application_configuration : application_configuration option;
    (*

    Use this parameter to configure the application.

    *)
  5. service_execution_role : role_ar_n;
    (*

    The IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.

    *)
  6. runtime_environment : runtime_environment;
    (*

    The runtime environment for the application.

    *)
  7. application_description : application_description option;
    (*

    A summary description of the application.

    *)
  8. application_name : application_name;
    (*

    The name of your application (for example, sample-app).

    *)
}
type nonrec add_application_vpc_configuration_response = {
  1. operation_id : operation_id option;
    (*

    Operation ID for tracking AddApplicationVpcConfiguration request

    *)
  2. vpc_configuration_description : vpc_configuration_description option;
    (*

    The parameters of the new VPC configuration.

    *)
  3. application_version_id : application_version_id option;
    (*

    Provides the current application version. Managed Service for Apache Flink updates the ApplicationVersionId each time you update the application.

    *)
  4. application_ar_n : resource_ar_n option;
    (*

    The ARN of the application.

    *)
}
type nonrec add_application_vpc_configuration_request = {
  1. conditional_token : conditional_token option;
    (*

    A value you use to implement strong concurrency for application updates. You must provide the ApplicationVersionID or the ConditionalToken. You get the application's current ConditionalToken using DescribeApplication. For better concurrency support, use the ConditionalToken parameter instead of CurrentApplicationVersionId.

    *)
  2. vpc_configuration : vpc_configuration;
    (*

    Description of the VPC to add to the application.

    *)
  3. current_application_version_id : application_version_id option;
    (*

    The version of the application to which you want to add the VPC configuration. You must provide the CurrentApplicationVersionId or the ConditionalToken. You can use the DescribeApplication operation to get the current application version. If the version specified is not the current version, the ConcurrentModificationException is returned. For better concurrency support, use the ConditionalToken parameter instead of CurrentApplicationVersionId.

    *)
  4. application_name : application_name;
    (*

    The name of an existing application.

    *)
}
type nonrec add_application_reference_data_source_response = {
  1. reference_data_source_descriptions : reference_data_source_descriptions option;
    (*

    Describes reference data sources configured for the application.

    *)
  2. application_version_id : application_version_id option;
    (*

    The updated application version ID. Kinesis Data Analytics increments this ID when the application is updated.

    *)
  3. application_ar_n : resource_ar_n option;
    (*

    The application Amazon Resource Name (ARN).

    *)
}
type nonrec add_application_reference_data_source_request = {
  1. reference_data_source : reference_data_source;
    (*

    The reference data source can be an object in your Amazon S3 bucket. Kinesis Data Analytics reads the object and copies the data into the in-application table that is created. You provide an S3 bucket, object key name, and the resulting in-application table that is created.

    *)
  2. current_application_version_id : application_version_id;
    (*

    The version of the application for which you are adding the reference data source. You can use the DescribeApplication operation to get the current application version. If the version specified is not the current version, the ConcurrentModificationException is returned.

    *)
  3. application_name : application_name;
    (*

    The name of an existing application.

    *)
}
type nonrec add_application_output_response = {
  1. output_descriptions : output_descriptions option;
    (*

    Describes the application output configuration. For more information, see Configuring Application Output.

    *)
  2. application_version_id : application_version_id option;
    (*

    The updated application version ID. Kinesis Data Analytics increments this ID when the application is updated.

    *)
  3. application_ar_n : resource_ar_n option;
    (*

    The application Amazon Resource Name (ARN).

    *)
}
type nonrec add_application_output_request = {
  1. output : output;
    (*

    An array of objects, each describing one output configuration. In the output configuration, you specify the name of an in-application stream, a destination (that is, a Kinesis data stream, a Kinesis Data Firehose delivery stream, or an Amazon Lambda function), and record the formation to use when writing to the destination.

    *)
  2. current_application_version_id : application_version_id;
    (*

    The version of the application to which you want to add the output configuration. You can use the DescribeApplication operation to get the current application version. If the version specified is not the current version, the ConcurrentModificationException is returned.

    *)
  3. application_name : application_name;
    (*

    The name of the application to which you want to add the output configuration.

    *)
}
type nonrec add_application_input_processing_configuration_response = {
  1. input_processing_configuration_description : input_processing_configuration_description option;
    (*

    The description of the preprocessor that executes on records in this input before the application's code is run.

    *)
  2. input_id : id option;
    (*

    The input ID that is associated with the application input. This is the ID that Kinesis Data Analytics assigns to each input configuration that you add to your application.

    *)
  3. application_version_id : application_version_id option;
    (*

    Provides the current application version.

    *)
  4. application_ar_n : resource_ar_n option;
    (*

    The Amazon Resource Name (ARN) of the application.

    *)
}
type nonrec add_application_input_processing_configuration_request = {
  1. input_processing_configuration : input_processing_configuration;
    (*

    The InputProcessingConfiguration to add to the application.

    *)
  2. input_id : id;
    (*

    The ID of the input configuration to add the input processing configuration to. You can get a list of the input IDs for an application using the DescribeApplication operation.

    *)
  3. current_application_version_id : application_version_id;
    (*

    The version of the application to which you want to add the input processing configuration. You can use the DescribeApplication operation to get the current application version. If the version specified is not the current version, the ConcurrentModificationException is returned.

    *)
  4. application_name : application_name;
    (*

    The name of the application to which you want to add the input processing configuration.

    *)
}
type nonrec add_application_input_response = {
  1. input_descriptions : input_descriptions option;
    (*

    Describes the application input configuration.

    *)
  2. application_version_id : application_version_id option;
    (*

    Provides the current application version.

    *)
  3. application_ar_n : resource_ar_n option;
    (*

    The Amazon Resource Name (ARN) of the application.

    *)
}
type nonrec add_application_input_request = {
  1. input : input;
    (*

    The Input to add.

    *)
  2. current_application_version_id : application_version_id;
    (*

    The current version of your application. You must provide the ApplicationVersionID or the ConditionalToken.You can use the DescribeApplication operation to find the current application version.

    *)
  3. application_name : application_name;
    (*

    The name of your existing application to which you want to add the streaming source.

    *)
}
type nonrec add_application_cloud_watch_logging_option_response = {
  1. operation_id : operation_id option;
    (*

    Operation ID for tracking AddApplicationCloudWatchLoggingOption request

    *)
  2. cloud_watch_logging_option_descriptions : cloud_watch_logging_option_descriptions option;
    (*

    The descriptions of the current CloudWatch logging options for the SQL-based Kinesis Data Analytics application.

    *)
  3. application_version_id : application_version_id option;
    (*

    The new version ID of the SQL-based Kinesis Data Analytics application. Kinesis Data Analytics updates the ApplicationVersionId each time you change the CloudWatch logging options.

    *)
  4. application_ar_n : resource_ar_n option;
    (*

    The application's ARN.

    *)
}
type nonrec add_application_cloud_watch_logging_option_request = {
  1. conditional_token : conditional_token option;
    (*

    A value you use to implement strong concurrency for application updates. You must provide the CurrentApplicationVersionId or the ConditionalToken. You get the application's current ConditionalToken using DescribeApplication. For better concurrency support, use the ConditionalToken parameter instead of CurrentApplicationVersionId.

    *)
  2. cloud_watch_logging_option : cloud_watch_logging_option;
    (*

    Provides the Amazon CloudWatch log stream Amazon Resource Name (ARN).

    *)
  3. current_application_version_id : application_version_id option;
    (*

    The version ID of the SQL-based Kinesis Data Analytics application. You must provide the CurrentApplicationVersionId or the ConditionalToken.You can retrieve the application version ID using DescribeApplication. For better concurrency support, use the ConditionalToken parameter instead of CurrentApplicationVersionId.

    *)
  4. application_name : application_name;
    (*

    The Kinesis Data Analytics application name.

    *)
}