Module Smaws_Client_KinesisAnalyticsV2

Kinesis Analytics V2 client library built on EIO.

Types

module Types : sig ... end

Builders

val make_zeppelin_monitoring_configuration_update : log_level_update:Types.log_level -> unit -> Types.zeppelin_monitoring_configuration_update
val make_zeppelin_monitoring_configuration_description : ?log_level:Types.log_level -> unit -> Types.zeppelin_monitoring_configuration_description
val make_zeppelin_monitoring_configuration : log_level:Types.log_level -> unit -> Types.zeppelin_monitoring_configuration
val make_glue_data_catalog_configuration_update : database_arn_update:Types.database_ar_n -> unit -> Types.glue_data_catalog_configuration_update
val make_catalog_configuration_update : glue_data_catalog_configuration_update: Types.glue_data_catalog_configuration_update -> unit -> Types.catalog_configuration_update
val make_s3_content_base_location_update : ?base_path_update:Types.base_path -> ?bucket_arn_update:Types.bucket_ar_n -> unit -> Types.s3_content_base_location_update
val make_deploy_as_application_configuration_update : ?s3_content_location_update:Types.s3_content_base_location_update -> unit -> Types.deploy_as_application_configuration_update
val make_s3_content_location : ?object_version:Types.object_version -> file_key:Types.file_key -> bucket_ar_n:Types.bucket_ar_n -> unit -> Types.s3_content_location
val make_maven_reference : version:Types.maven_version -> artifact_id:Types.maven_artifact_id -> group_id:Types.maven_group_id -> unit -> Types.maven_reference
val make_custom_artifact_configuration : ?maven_reference:Types.maven_reference -> ?s3_content_location:Types.s3_content_location -> artifact_type:Types.artifact_type -> unit -> Types.custom_artifact_configuration
val make_zeppelin_application_configuration_update : ?custom_artifacts_configuration_update: Types.custom_artifacts_configuration_list -> ?deploy_as_application_configuration_update: Types.deploy_as_application_configuration_update -> ?catalog_configuration_update:Types.catalog_configuration_update -> ?monitoring_configuration_update: Types.zeppelin_monitoring_configuration_update -> unit -> Types.zeppelin_application_configuration_update
val make_glue_data_catalog_configuration_description : database_ar_n:Types.database_ar_n -> unit -> Types.glue_data_catalog_configuration_description
val make_catalog_configuration_description : glue_data_catalog_configuration_description: Types.glue_data_catalog_configuration_description -> unit -> Types.catalog_configuration_description
val make_s3_content_base_location_description : ?base_path:Types.base_path -> bucket_ar_n:Types.bucket_ar_n -> unit -> Types.s3_content_base_location_description
val make_deploy_as_application_configuration_description : s3_content_location_description:Types.s3_content_base_location_description -> unit -> Types.deploy_as_application_configuration_description
val make_custom_artifact_configuration_description : ?maven_reference_description:Types.maven_reference -> ?s3_content_location_description:Types.s3_content_location -> ?artifact_type:Types.artifact_type -> unit -> Types.custom_artifact_configuration_description
val make_zeppelin_application_configuration_description : ?custom_artifacts_configuration_description: Types.custom_artifacts_configuration_description_list -> ?deploy_as_application_configuration_description: Types.deploy_as_application_configuration_description -> ?catalog_configuration_description:Types.catalog_configuration_description -> monitoring_configuration_description: Types.zeppelin_monitoring_configuration_description -> unit -> Types.zeppelin_application_configuration_description
val make_glue_data_catalog_configuration : database_ar_n:Types.database_ar_n -> unit -> Types.glue_data_catalog_configuration
val make_catalog_configuration : glue_data_catalog_configuration:Types.glue_data_catalog_configuration -> unit -> Types.catalog_configuration
val make_s3_content_base_location : ?base_path:Types.base_path -> bucket_ar_n:Types.bucket_ar_n -> unit -> Types.s3_content_base_location
val make_deploy_as_application_configuration : s3_content_location:Types.s3_content_base_location -> unit -> Types.deploy_as_application_configuration
val make_zeppelin_application_configuration : ?custom_artifacts_configuration:Types.custom_artifacts_configuration_list -> ?deploy_as_application_configuration: Types.deploy_as_application_configuration -> ?catalog_configuration:Types.catalog_configuration -> ?monitoring_configuration:Types.zeppelin_monitoring_configuration -> unit -> Types.zeppelin_application_configuration
val make_vpc_configuration : security_group_ids:Types.security_group_ids -> subnet_ids:Types.subnet_ids -> unit -> Types.vpc_configuration
val make_vpc_configuration_update : ?security_group_id_updates:Types.security_group_ids -> ?subnet_id_updates:Types.subnet_ids -> vpc_configuration_id:Types.id -> unit -> Types.vpc_configuration_update
val make_vpc_configuration_description : security_group_ids:Types.security_group_ids -> subnet_ids:Types.subnet_ids -> vpc_id:Types.vpc_id -> vpc_configuration_id:Types.id -> unit -> Types.vpc_configuration_description
val make_input_lambda_processor_description : ?role_ar_n:Types.role_ar_n -> resource_ar_n:Types.resource_ar_n -> unit -> Types.input_lambda_processor_description
val make_input_processing_configuration_description : ?input_lambda_processor_description:Types.input_lambda_processor_description -> unit -> Types.input_processing_configuration_description
val make_kinesis_streams_input_description : ?role_ar_n:Types.role_ar_n -> resource_ar_n:Types.resource_ar_n -> unit -> Types.kinesis_streams_input_description
val make_kinesis_firehose_input_description : ?role_ar_n:Types.role_ar_n -> resource_ar_n:Types.resource_ar_n -> unit -> Types.kinesis_firehose_input_description
val make_json_mapping_parameters : record_row_path:Types.record_row_path -> unit -> Types.json_mapping_parameters
val make_csv_mapping_parameters : record_column_delimiter:Types.record_column_delimiter -> record_row_delimiter:Types.record_row_delimiter -> unit -> Types.csv_mapping_parameters
val make_mapping_parameters : ?csv_mapping_parameters:Types.csv_mapping_parameters -> ?json_mapping_parameters:Types.json_mapping_parameters -> unit -> Types.mapping_parameters
val make_record_format : ?mapping_parameters:Types.mapping_parameters -> record_format_type:Types.record_format_type -> unit -> Types.record_format
val make_record_column : ?mapping:Types.record_column_mapping -> sql_type:Types.record_column_sql_type -> name:Types.record_column_name -> unit -> Types.record_column
val make_source_schema : ?record_encoding:Types.record_encoding -> record_columns:Types.record_columns -> record_format:Types.record_format -> unit -> Types.source_schema
val make_input_parallelism : ?count:Types.input_parallelism_count -> unit -> Types.input_parallelism
val make_input_starting_position_configuration : ?input_starting_position:Types.input_starting_position -> unit -> Types.input_starting_position_configuration
val make_input_description : ?input_starting_position_configuration: Types.input_starting_position_configuration -> ?input_parallelism:Types.input_parallelism -> ?input_schema:Types.source_schema -> ?kinesis_firehose_input_description:Types.kinesis_firehose_input_description -> ?kinesis_streams_input_description:Types.kinesis_streams_input_description -> ?input_processing_configuration_description: Types.input_processing_configuration_description -> ?in_app_stream_names:Types.in_app_stream_names -> ?name_prefix:Types.in_app_stream_name -> ?input_id:Types.id -> unit -> Types.input_description
val make_kinesis_streams_output_description : ?role_ar_n:Types.role_ar_n -> resource_ar_n:Types.resource_ar_n -> unit -> Types.kinesis_streams_output_description
val make_kinesis_firehose_output_description : ?role_ar_n:Types.role_ar_n -> resource_ar_n:Types.resource_ar_n -> unit -> Types.kinesis_firehose_output_description
val make_lambda_output_description : ?role_ar_n:Types.role_ar_n -> resource_ar_n:Types.resource_ar_n -> unit -> Types.lambda_output_description
val make_destination_schema : record_format_type:Types.record_format_type -> unit -> Types.destination_schema
val make_output_description : ?destination_schema:Types.destination_schema -> ?lambda_output_description:Types.lambda_output_description -> ?kinesis_firehose_output_description: Types.kinesis_firehose_output_description -> ?kinesis_streams_output_description:Types.kinesis_streams_output_description -> ?name:Types.in_app_stream_name -> ?output_id:Types.id -> unit -> Types.output_description
val make_s3_reference_data_source_description : ?reference_role_ar_n:Types.role_ar_n -> file_key:Types.file_key -> bucket_ar_n:Types.bucket_ar_n -> unit -> Types.s3_reference_data_source_description
val make_reference_data_source_description : ?reference_schema:Types.source_schema -> s3_reference_data_source_description: Types.s3_reference_data_source_description -> table_name:Types.in_app_table_name -> reference_id:Types.id -> unit -> Types.reference_data_source_description
val make_sql_application_configuration_description : ?reference_data_source_descriptions:Types.reference_data_source_descriptions -> ?output_descriptions:Types.output_descriptions -> ?input_descriptions:Types.input_descriptions -> unit -> Types.sql_application_configuration_description
val make_s3_application_code_location_description : ?object_version:Types.object_version -> file_key:Types.file_key -> bucket_ar_n:Types.bucket_ar_n -> unit -> Types.s3_application_code_location_description
val make_code_content_description : ?s3_application_code_location_description: Types.s3_application_code_location_description -> ?code_size:Types.code_size -> ?code_m_d5:Types.code_m_d5 -> ?text_content:Types.text_content -> unit -> Types.code_content_description
val make_application_code_configuration_description : ?code_content_description:Types.code_content_description -> code_content_type:Types.code_content_type -> unit -> Types.application_code_configuration_description
val make_application_restore_configuration : ?snapshot_name:Types.snapshot_name -> application_restore_type:Types.application_restore_type -> unit -> Types.application_restore_configuration
val make_run_configuration_description : ?flink_run_configuration_description:Types.flink_run_configuration -> ?application_restore_configuration_description: Types.application_restore_configuration -> unit -> Types.run_configuration_description
val make_checkpoint_configuration_description : ?min_pause_between_checkpoints:Types.min_pause_between_checkpoints -> ?checkpoint_interval:Types.checkpoint_interval -> ?checkpointing_enabled:Types.boolean_object -> ?configuration_type:Types.configuration_type -> unit -> Types.checkpoint_configuration_description
val make_monitoring_configuration_description : ?log_level:Types.log_level -> ?metrics_level:Types.metrics_level -> ?configuration_type:Types.configuration_type -> unit -> Types.monitoring_configuration_description
val make_parallelism_configuration_description : ?auto_scaling_enabled:Types.boolean_object -> ?current_parallelism:Types.parallelism -> ?parallelism_per_kp_u:Types.parallelism_per_kp_u -> ?parallelism:Types.parallelism -> ?configuration_type:Types.configuration_type -> unit -> Types.parallelism_configuration_description
val make_property_group : property_map:Types.property_map -> property_group_id:Types.id -> unit -> Types.property_group
val make_environment_property_descriptions : ?property_group_descriptions:Types.property_groups -> unit -> Types.environment_property_descriptions
val make_application_snapshot_configuration_description : snapshots_enabled:Types.boolean_object -> unit -> Types.application_snapshot_configuration_description
val make_application_system_rollback_configuration_description : rollback_enabled:Types.boolean_object -> unit -> Types.application_system_rollback_configuration_description
val make_application_configuration_description : ?zeppelin_application_configuration_description: Types.zeppelin_application_configuration_description -> ?vpc_configuration_descriptions:Types.vpc_configuration_descriptions -> ?application_system_rollback_configuration_description: Types.application_system_rollback_configuration_description -> ?application_snapshot_configuration_description: Types.application_snapshot_configuration_description -> ?environment_property_descriptions:Types.environment_property_descriptions -> ?flink_application_configuration_description: Types.flink_application_configuration_description -> ?run_configuration_description:Types.run_configuration_description -> ?application_code_configuration_description: Types.application_code_configuration_description -> ?sql_application_configuration_description: Types.sql_application_configuration_description -> unit -> Types.application_configuration_description
val make_cloud_watch_logging_option_description : ?role_ar_n:Types.role_ar_n -> ?cloud_watch_logging_option_id:Types.id -> log_stream_ar_n:Types.log_stream_ar_n -> unit -> Types.cloud_watch_logging_option_description
val make_application_maintenance_configuration_description : application_maintenance_window_end_time: Types.application_maintenance_window_end_time -> application_maintenance_window_start_time: Types.application_maintenance_window_start_time -> unit -> Types.application_maintenance_configuration_description
val make_application_detail : ?application_mode:Types.application_mode -> ?application_version_rolled_back_to:Types.application_version_id -> ?conditional_token:Types.conditional_token -> ?application_version_create_timestamp:Types.timestamp -> ?application_version_rolled_back_from:Types.application_version_id -> ?application_version_updated_from:Types.application_version_id -> ?application_maintenance_configuration_description: Types.application_maintenance_configuration_description -> ?cloud_watch_logging_option_descriptions: Types.cloud_watch_logging_option_descriptions -> ?application_configuration_description: Types.application_configuration_description -> ?last_update_timestamp:Types.timestamp -> ?create_timestamp:Types.timestamp -> ?service_execution_role:Types.role_ar_n -> ?application_description:Types.application_description -> application_version_id:Types.application_version_id -> application_status:Types.application_status -> runtime_environment:Types.runtime_environment -> application_name:Types.application_name -> application_ar_n:Types.resource_ar_n -> unit -> Types.application_detail
val make_update_application_response : ?operation_id:Types.operation_id -> application_detail:Types.application_detail -> unit -> Types.update_application_response
val make_input_lambda_processor_update : resource_arn_update:Types.resource_ar_n -> unit -> Types.input_lambda_processor_update
val make_input_processing_configuration_update : input_lambda_processor_update:Types.input_lambda_processor_update -> unit -> Types.input_processing_configuration_update
val make_kinesis_streams_input_update : resource_arn_update:Types.resource_ar_n -> unit -> Types.kinesis_streams_input_update
val make_kinesis_firehose_input_update : resource_arn_update:Types.resource_ar_n -> unit -> Types.kinesis_firehose_input_update
val make_input_schema_update : ?record_column_updates:Types.record_columns -> ?record_encoding_update:Types.record_encoding -> ?record_format_update:Types.record_format -> unit -> Types.input_schema_update
val make_input_parallelism_update : count_update:Types.input_parallelism_count -> unit -> Types.input_parallelism_update
val make_input_update : ?input_parallelism_update:Types.input_parallelism_update -> ?input_schema_update:Types.input_schema_update -> ?kinesis_firehose_input_update:Types.kinesis_firehose_input_update -> ?kinesis_streams_input_update:Types.kinesis_streams_input_update -> ?input_processing_configuration_update: Types.input_processing_configuration_update -> ?name_prefix_update:Types.in_app_stream_name -> input_id:Types.id -> unit -> Types.input_update
val make_kinesis_streams_output_update : resource_arn_update:Types.resource_ar_n -> unit -> Types.kinesis_streams_output_update
val make_kinesis_firehose_output_update : resource_arn_update:Types.resource_ar_n -> unit -> Types.kinesis_firehose_output_update
val make_lambda_output_update : resource_arn_update:Types.resource_ar_n -> unit -> Types.lambda_output_update
val make_output_update : ?destination_schema_update:Types.destination_schema -> ?lambda_output_update:Types.lambda_output_update -> ?kinesis_firehose_output_update:Types.kinesis_firehose_output_update -> ?kinesis_streams_output_update:Types.kinesis_streams_output_update -> ?name_update:Types.in_app_stream_name -> output_id:Types.id -> unit -> Types.output_update
val make_s3_reference_data_source_update : ?file_key_update:Types.file_key -> ?bucket_arn_update:Types.bucket_ar_n -> unit -> Types.s3_reference_data_source_update
val make_reference_data_source_update : ?reference_schema_update:Types.source_schema -> ?s3_reference_data_source_update:Types.s3_reference_data_source_update -> ?table_name_update:Types.in_app_table_name -> reference_id:Types.id -> unit -> Types.reference_data_source_update
val make_sql_application_configuration_update : ?reference_data_source_updates:Types.reference_data_source_updates -> ?output_updates:Types.output_updates -> ?input_updates:Types.input_updates -> unit -> Types.sql_application_configuration_update
val make_s3_content_location_update : ?object_version_update:Types.object_version -> ?file_key_update:Types.file_key -> ?bucket_arn_update:Types.bucket_ar_n -> unit -> Types.s3_content_location_update
val make_code_content_update : ?s3_content_location_update:Types.s3_content_location_update -> ?zip_file_content_update:Types.zip_file_content -> ?text_content_update:Types.text_content -> unit -> Types.code_content_update
val make_application_code_configuration_update : ?code_content_update:Types.code_content_update -> ?code_content_type_update:Types.code_content_type -> unit -> Types.application_code_configuration_update
val make_checkpoint_configuration_update : ?min_pause_between_checkpoints_update:Types.min_pause_between_checkpoints -> ?checkpoint_interval_update:Types.checkpoint_interval -> ?checkpointing_enabled_update:Types.boolean_object -> ?configuration_type_update:Types.configuration_type -> unit -> Types.checkpoint_configuration_update
val make_monitoring_configuration_update : ?log_level_update:Types.log_level -> ?metrics_level_update:Types.metrics_level -> ?configuration_type_update:Types.configuration_type -> unit -> Types.monitoring_configuration_update
val make_parallelism_configuration_update : ?auto_scaling_enabled_update:Types.boolean_object -> ?parallelism_per_kpu_update:Types.parallelism_per_kp_u -> ?parallelism_update:Types.parallelism -> ?configuration_type_update:Types.configuration_type -> unit -> Types.parallelism_configuration_update
val make_environment_property_updates : property_groups:Types.property_groups -> unit -> Types.environment_property_updates
val make_application_snapshot_configuration_update : snapshots_enabled_update:Types.boolean_object -> unit -> Types.application_snapshot_configuration_update
val make_application_system_rollback_configuration_update : rollback_enabled_update:Types.boolean_object -> unit -> Types.application_system_rollback_configuration_update
val make_application_configuration_update : ?zeppelin_application_configuration_update: Types.zeppelin_application_configuration_update -> ?vpc_configuration_updates:Types.vpc_configuration_updates -> ?application_system_rollback_configuration_update: Types.application_system_rollback_configuration_update -> ?application_snapshot_configuration_update: Types.application_snapshot_configuration_update -> ?environment_property_updates:Types.environment_property_updates -> ?flink_application_configuration_update: Types.flink_application_configuration_update -> ?application_code_configuration_update: Types.application_code_configuration_update -> ?sql_application_configuration_update: Types.sql_application_configuration_update -> unit -> Types.application_configuration_update
val make_run_configuration_update : ?application_restore_configuration:Types.application_restore_configuration -> ?flink_run_configuration:Types.flink_run_configuration -> unit -> Types.run_configuration_update
val make_cloud_watch_logging_option_update : ?log_stream_arn_update:Types.log_stream_ar_n -> cloud_watch_logging_option_id:Types.id -> unit -> Types.cloud_watch_logging_option_update
val make_update_application_request : ?runtime_environment_update:Types.runtime_environment -> ?conditional_token:Types.conditional_token -> ?cloud_watch_logging_option_updates:Types.cloud_watch_logging_option_updates -> ?run_configuration_update:Types.run_configuration_update -> ?service_execution_role_update:Types.role_ar_n -> ?application_configuration_update:Types.application_configuration_update -> ?current_application_version_id:Types.application_version_id -> application_name:Types.application_name -> unit -> Types.update_application_request
val make_update_application_maintenance_configuration_response : ?application_maintenance_configuration_description: Types.application_maintenance_configuration_description -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.update_application_maintenance_configuration_response
val make_application_maintenance_configuration_update : application_maintenance_window_start_time_update: Types.application_maintenance_window_start_time -> unit -> Types.application_maintenance_configuration_update
val make_update_application_maintenance_configuration_request : application_maintenance_configuration_update: Types.application_maintenance_configuration_update -> application_name:Types.application_name -> unit -> Types.update_application_maintenance_configuration_request
val make_untag_resource_response : unit -> unit
val make_untag_resource_request : tag_keys:Types.tag_keys -> resource_ar_n:Types.kinesis_analytics_ar_n -> unit -> Types.untag_resource_request
val make_tag : ?value:Types.tag_value -> key:Types.tag_key -> unit -> Types.tag
val make_tag_resource_response : unit -> unit
val make_tag_resource_request : tags:Types.tags -> resource_ar_n:Types.kinesis_analytics_ar_n -> unit -> Types.tag_resource_request
val make_stop_application_response : ?operation_id:Types.operation_id -> unit -> Types.stop_application_response
val make_stop_application_request : ?force:Types.boolean_object -> application_name:Types.application_name -> unit -> Types.stop_application_request
val make_start_application_response : ?operation_id:Types.operation_id -> unit -> Types.start_application_response
val make_sql_run_configuration : input_starting_position_configuration: Types.input_starting_position_configuration -> input_id:Types.id -> unit -> Types.sql_run_configuration
val make_run_configuration : ?application_restore_configuration:Types.application_restore_configuration -> ?sql_run_configurations:Types.sql_run_configurations -> ?flink_run_configuration:Types.flink_run_configuration -> unit -> Types.run_configuration
val make_start_application_request : ?run_configuration:Types.run_configuration -> application_name:Types.application_name -> unit -> Types.start_application_request
val make_input_lambda_processor : resource_ar_n:Types.resource_ar_n -> unit -> Types.input_lambda_processor
val make_input_processing_configuration : input_lambda_processor:Types.input_lambda_processor -> unit -> Types.input_processing_configuration
val make_kinesis_streams_input : resource_ar_n:Types.resource_ar_n -> unit -> Types.kinesis_streams_input
val make_kinesis_firehose_input : resource_ar_n:Types.resource_ar_n -> unit -> Types.kinesis_firehose_input
val make_input : ?input_parallelism:Types.input_parallelism -> ?kinesis_firehose_input:Types.kinesis_firehose_input -> ?kinesis_streams_input:Types.kinesis_streams_input -> ?input_processing_configuration:Types.input_processing_configuration -> input_schema:Types.source_schema -> name_prefix:Types.in_app_stream_name -> unit -> Types.input
val make_kinesis_streams_output : resource_ar_n:Types.resource_ar_n -> unit -> Types.kinesis_streams_output
val make_kinesis_firehose_output : resource_ar_n:Types.resource_ar_n -> unit -> Types.kinesis_firehose_output
val make_lambda_output : resource_ar_n:Types.resource_ar_n -> unit -> Types.lambda_output
val make_output : ?lambda_output:Types.lambda_output -> ?kinesis_firehose_output:Types.kinesis_firehose_output -> ?kinesis_streams_output:Types.kinesis_streams_output -> destination_schema:Types.destination_schema -> name:Types.in_app_stream_name -> unit -> Types.output
val make_s3_reference_data_source : ?file_key:Types.file_key -> ?bucket_ar_n:Types.bucket_ar_n -> unit -> Types.s3_reference_data_source
val make_reference_data_source : ?s3_reference_data_source:Types.s3_reference_data_source -> reference_schema:Types.source_schema -> table_name:Types.in_app_table_name -> unit -> Types.reference_data_source
val make_sql_application_configuration : ?reference_data_sources:Types.reference_data_sources -> ?outputs:Types.outputs -> ?inputs:Types.inputs -> unit -> Types.sql_application_configuration
val make_snapshot_details : ?runtime_environment:Types.runtime_environment -> ?snapshot_creation_timestamp:Types.timestamp -> application_version_id:Types.application_version_id -> snapshot_status:Types.snapshot_status -> snapshot_name:Types.snapshot_name -> unit -> Types.snapshot_details
val make_s3_configuration : file_key:Types.file_key -> bucket_ar_n:Types.bucket_ar_n -> unit -> Types.s3_configuration
val make_rollback_application_response : ?operation_id:Types.operation_id -> application_detail:Types.application_detail -> unit -> Types.rollback_application_response
val make_rollback_application_request : current_application_version_id:Types.application_version_id -> application_name:Types.application_name -> unit -> Types.rollback_application_request
val make_parallelism_configuration : ?auto_scaling_enabled:Types.boolean_object -> ?parallelism_per_kp_u:Types.parallelism_per_kp_u -> ?parallelism:Types.parallelism -> configuration_type:Types.configuration_type -> unit -> Types.parallelism_configuration
val make_error_info : ?error_string:Types.error_string -> unit -> Types.error_info
val make_operation_failure_details : ?error_info:Types.error_info -> ?rollback_operation_id:Types.operation_id -> unit -> Types.operation_failure_details
val make_monitoring_configuration : ?log_level:Types.log_level -> ?metrics_level:Types.metrics_level -> configuration_type:Types.configuration_type -> unit -> Types.monitoring_configuration
val make_list_tags_for_resource_response : ?tags:Types.tags -> unit -> Types.list_tags_for_resource_response
val make_list_tags_for_resource_request : resource_ar_n:Types.kinesis_analytics_ar_n -> unit -> Types.list_tags_for_resource_request
val make_application_summary : ?application_mode:Types.application_mode -> runtime_environment:Types.runtime_environment -> application_version_id:Types.application_version_id -> application_status:Types.application_status -> application_ar_n:Types.resource_ar_n -> application_name:Types.application_name -> unit -> Types.application_summary
val make_list_applications_response : ?next_token:Types.application_name -> application_summaries:Types.application_summaries -> unit -> Types.list_applications_response
val make_list_applications_request : ?next_token:Types.application_name -> ?limit:Types.list_applications_input_limit -> unit -> Types.list_applications_request
val make_application_version_summary : application_status:Types.application_status -> application_version_id:Types.application_version_id -> unit -> Types.application_version_summary
val make_list_application_versions_response : ?next_token:Types.next_token -> ?application_version_summaries:Types.application_version_summaries -> unit -> Types.list_application_versions_response
val make_list_application_versions_request : ?next_token:Types.next_token -> ?limit:Types.list_application_versions_input_limit -> application_name:Types.application_name -> unit -> Types.list_application_versions_request
val make_list_application_snapshots_response : ?next_token:Types.next_token -> ?snapshot_summaries:Types.snapshot_summaries -> unit -> Types.list_application_snapshots_response
val make_list_application_snapshots_request : ?next_token:Types.next_token -> ?limit:Types.list_snapshots_input_limit -> application_name:Types.application_name -> unit -> Types.list_application_snapshots_request
val make_application_operation_info : ?operation_status:Types.operation_status -> ?end_time:Types.timestamp -> ?start_time:Types.timestamp -> ?operation_id:Types.operation_id -> ?operation:Types.operation -> unit -> Types.application_operation_info
val make_list_application_operations_response : ?next_token:Types.next_token -> ?application_operation_info_list:Types.application_operation_info_list -> unit -> Types.list_application_operations_response
val make_list_application_operations_request : ?operation_status:Types.operation_status -> ?operation:Types.operation -> ?next_token:Types.next_token -> ?limit:Types.list_application_operations_input_limit -> application_name:Types.application_name -> unit -> Types.list_application_operations_request
val make_discover_input_schema_response : ?raw_input_records:Types.raw_input_records -> ?processed_input_records:Types.processed_input_records -> ?parsed_input_records:Types.parsed_input_records -> ?input_schema:Types.source_schema -> unit -> Types.discover_input_schema_response
val make_discover_input_schema_request : ?input_processing_configuration:Types.input_processing_configuration -> ?s3_configuration:Types.s3_configuration -> ?input_starting_position_configuration: Types.input_starting_position_configuration -> ?resource_ar_n:Types.resource_ar_n -> service_execution_role:Types.role_ar_n -> unit -> Types.discover_input_schema_request
val make_describe_application_version_response : ?application_version_detail:Types.application_detail -> unit -> Types.describe_application_version_response
val make_describe_application_version_request : application_version_id:Types.application_version_id -> application_name:Types.application_name -> unit -> Types.describe_application_version_request
val make_describe_application_snapshot_response : snapshot_details:Types.snapshot_details -> unit -> Types.describe_application_snapshot_response
val make_describe_application_snapshot_request : snapshot_name:Types.snapshot_name -> application_name:Types.application_name -> unit -> Types.describe_application_snapshot_request
val make_application_version_change_details : application_version_updated_to:Types.application_version_id -> application_version_updated_from:Types.application_version_id -> unit -> Types.application_version_change_details
val make_application_operation_info_details : ?operation_failure_details:Types.operation_failure_details -> ?application_version_change_details:Types.application_version_change_details -> operation_status:Types.operation_status -> end_time:Types.timestamp -> start_time:Types.timestamp -> operation:Types.operation -> unit -> Types.application_operation_info_details
val make_describe_application_operation_response : ?application_operation_info_details:Types.application_operation_info_details -> unit -> Types.describe_application_operation_response
val make_describe_application_operation_request : operation_id:Types.operation_id -> application_name:Types.application_name -> unit -> Types.describe_application_operation_request
val make_describe_application_response : application_detail:Types.application_detail -> unit -> Types.describe_application_response
val make_describe_application_request : ?include_additional_details:Types.boolean_object -> application_name:Types.application_name -> unit -> Types.describe_application_request
val make_delete_application_vpc_configuration_response : ?operation_id:Types.operation_id -> ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.delete_application_vpc_configuration_response
val make_delete_application_vpc_configuration_request : ?conditional_token:Types.conditional_token -> ?current_application_version_id:Types.application_version_id -> vpc_configuration_id:Types.id -> application_name:Types.application_name -> unit -> Types.delete_application_vpc_configuration_request
val make_delete_application_snapshot_response : unit -> unit
val make_delete_application_snapshot_request : snapshot_creation_timestamp:Types.timestamp -> snapshot_name:Types.snapshot_name -> application_name:Types.application_name -> unit -> Types.delete_application_snapshot_request
val make_delete_application_reference_data_source_response : ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.delete_application_reference_data_source_response
val make_delete_application_reference_data_source_request : reference_id:Types.id -> current_application_version_id:Types.application_version_id -> application_name:Types.application_name -> unit -> Types.delete_application_reference_data_source_request
val make_delete_application_output_response : ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.delete_application_output_response
val make_delete_application_output_request : output_id:Types.id -> current_application_version_id:Types.application_version_id -> application_name:Types.application_name -> unit -> Types.delete_application_output_request
val make_delete_application_input_processing_configuration_response : ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.delete_application_input_processing_configuration_response
val make_delete_application_input_processing_configuration_request : input_id:Types.id -> current_application_version_id:Types.application_version_id -> application_name:Types.application_name -> unit -> Types.delete_application_input_processing_configuration_request
val make_delete_application_cloud_watch_logging_option_response : ?operation_id:Types.operation_id -> ?cloud_watch_logging_option_descriptions: Types.cloud_watch_logging_option_descriptions -> ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.delete_application_cloud_watch_logging_option_response
val make_delete_application_cloud_watch_logging_option_request : ?conditional_token:Types.conditional_token -> ?current_application_version_id:Types.application_version_id -> cloud_watch_logging_option_id:Types.id -> application_name:Types.application_name -> unit -> Types.delete_application_cloud_watch_logging_option_request
val make_delete_application_response : unit -> unit
val make_delete_application_request : create_timestamp:Types.timestamp -> application_name:Types.application_name -> unit -> Types.delete_application_request
val make_create_application_snapshot_response : unit -> unit
val make_create_application_snapshot_request : snapshot_name:Types.snapshot_name -> application_name:Types.application_name -> unit -> Types.create_application_snapshot_request
val make_create_application_presigned_url_response : ?authorized_url:Types.authorized_url -> unit -> Types.create_application_presigned_url_response
val make_create_application_presigned_url_request : ?session_expiration_duration_in_seconds: Types.session_expiration_duration_in_seconds -> url_type:Types.url_type -> application_name:Types.application_name -> unit -> Types.create_application_presigned_url_request
val make_create_application_response : application_detail:Types.application_detail -> unit -> Types.create_application_response
val make_checkpoint_configuration : ?min_pause_between_checkpoints:Types.min_pause_between_checkpoints -> ?checkpoint_interval:Types.checkpoint_interval -> ?checkpointing_enabled:Types.boolean_object -> configuration_type:Types.configuration_type -> unit -> Types.checkpoint_configuration
val make_environment_properties : property_groups:Types.property_groups -> unit -> Types.environment_properties
val make_code_content : ?s3_content_location:Types.s3_content_location -> ?zip_file_content:Types.zip_file_content -> ?text_content:Types.text_content -> unit -> Types.code_content
val make_application_code_configuration : ?code_content:Types.code_content -> code_content_type:Types.code_content_type -> unit -> Types.application_code_configuration
val make_application_snapshot_configuration : snapshots_enabled:Types.boolean_object -> unit -> Types.application_snapshot_configuration
val make_application_system_rollback_configuration : rollback_enabled:Types.boolean_object -> unit -> Types.application_system_rollback_configuration
val make_application_configuration : ?zeppelin_application_configuration:Types.zeppelin_application_configuration -> ?vpc_configurations:Types.vpc_configurations -> ?application_system_rollback_configuration: Types.application_system_rollback_configuration -> ?application_snapshot_configuration:Types.application_snapshot_configuration -> ?application_code_configuration:Types.application_code_configuration -> ?environment_properties:Types.environment_properties -> ?flink_application_configuration:Types.flink_application_configuration -> ?sql_application_configuration:Types.sql_application_configuration -> unit -> Types.application_configuration
val make_cloud_watch_logging_option : log_stream_ar_n:Types.log_stream_ar_n -> unit -> Types.cloud_watch_logging_option
val make_create_application_request : ?application_mode:Types.application_mode -> ?tags:Types.tags -> ?cloud_watch_logging_options:Types.cloud_watch_logging_options -> ?application_configuration:Types.application_configuration -> ?application_description:Types.application_description -> service_execution_role:Types.role_ar_n -> runtime_environment:Types.runtime_environment -> application_name:Types.application_name -> unit -> Types.create_application_request
val make_add_application_vpc_configuration_response : ?operation_id:Types.operation_id -> ?vpc_configuration_description:Types.vpc_configuration_description -> ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.add_application_vpc_configuration_response
val make_add_application_vpc_configuration_request : ?conditional_token:Types.conditional_token -> ?current_application_version_id:Types.application_version_id -> vpc_configuration:Types.vpc_configuration -> application_name:Types.application_name -> unit -> Types.add_application_vpc_configuration_request
val make_add_application_reference_data_source_response : ?reference_data_source_descriptions:Types.reference_data_source_descriptions -> ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.add_application_reference_data_source_response
val make_add_application_reference_data_source_request : reference_data_source:Types.reference_data_source -> current_application_version_id:Types.application_version_id -> application_name:Types.application_name -> unit -> Types.add_application_reference_data_source_request
val make_add_application_output_response : ?output_descriptions:Types.output_descriptions -> ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.add_application_output_response
val make_add_application_output_request : output:Types.output -> current_application_version_id:Types.application_version_id -> application_name:Types.application_name -> unit -> Types.add_application_output_request
val make_add_application_input_processing_configuration_response : ?input_processing_configuration_description: Types.input_processing_configuration_description -> ?input_id:Types.id -> ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.add_application_input_processing_configuration_response
val make_add_application_input_processing_configuration_request : input_processing_configuration:Types.input_processing_configuration -> input_id:Types.id -> current_application_version_id:Types.application_version_id -> application_name:Types.application_name -> unit -> Types.add_application_input_processing_configuration_request
val make_add_application_input_response : ?input_descriptions:Types.input_descriptions -> ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.add_application_input_response
val make_add_application_input_request : input:Types.input -> current_application_version_id:Types.application_version_id -> application_name:Types.application_name -> unit -> Types.add_application_input_request
val make_add_application_cloud_watch_logging_option_response : ?operation_id:Types.operation_id -> ?cloud_watch_logging_option_descriptions: Types.cloud_watch_logging_option_descriptions -> ?application_version_id:Types.application_version_id -> ?application_ar_n:Types.resource_ar_n -> unit -> Types.add_application_cloud_watch_logging_option_response
val make_add_application_cloud_watch_logging_option_request : ?conditional_token:Types.conditional_token -> ?current_application_version_id:Types.application_version_id -> cloud_watch_logging_option:Types.cloud_watch_logging_option -> application_name:Types.application_name -> unit -> Types.add_application_cloud_watch_logging_option_request

Operations

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

module AddApplicationInput : sig ... end

Adds a streaming source to your SQL-based Kinesis Data Analytics application.

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

module AddApplicationOutput : sig ... end

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

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

module AddApplicationVpcConfiguration : sig ... end

Adds a Virtual Private Cloud (VPC) configuration to the application. Applications can use VPCs to store and access resources securely.

module CreateApplication : sig ... end

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

module CreateApplicationPresignedUrl : sig ... end

Creates and returns a URL that you can use to connect to an application's extension.

module CreateApplicationSnapshot : sig ... end

Creates a snapshot of the application's state data.

module DeleteApplication : sig ... end

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

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

Deletes an InputProcessingConfiguration from an input.

module DeleteApplicationOutput : sig ... end

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

Deletes a reference data source configuration from the specified SQL-based Kinesis Data Analytics application's configuration.

module DeleteApplicationSnapshot : sig ... end

Deletes a snapshot of application state.

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

module DescribeApplication : sig ... end

Returns information about a specific Managed Service for Apache Flink application.

module DescribeApplicationOperation : sig ... end

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

module DescribeApplicationSnapshot : sig ... end

Returns information about a snapshot of application state data.

module DescribeApplicationVersion : sig ... end

Provides a detailed description of a specified version of the application. To see a list of all the versions of an application, invoke the ListApplicationVersions operation.

module DiscoverInputSchema : sig ... end

Infers a schema for a SQL-based Kinesis Data Analytics application by evaluating sample records on the specified streaming source (Kinesis data stream or Kinesis Data Firehose delivery stream) or Amazon S3 object. In the response, the operation returns the inferred schema and also the sample records that the operation used to infer the schema.

module ListApplicationOperations : sig ... end

Lists information about operations performed on a Managed Service for Apache Flink application

module ListApplicationSnapshots : sig ... end

Lists information about the current application snapshots.

module ListApplicationVersions : sig ... end

Lists all the versions for the specified application, including versions that were rolled back. The response also includes a summary of the configuration associated with each version.

module ListApplications : sig ... end

Returns a list of Managed Service for Apache Flink applications in your account. For each application, the response includes the application name, Amazon Resource Name (ARN), and status.

module ListTagsForResource : sig ... end

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

module RollbackApplication : sig ... end

Reverts the application to the previous running version. You can roll back an application if you suspect it is stuck in a transient status or in the running status.

module StartApplication : sig ... end

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

module StopApplication : sig ... end

Stops the application from processing data. You can stop an application only if it is in the running status, unless you set the Force parameter to true.

module TagResource : sig ... end

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

module UntagResource : sig ... end

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

module UpdateApplication : sig ... end

Updates an existing Managed Service for Apache Flink application. Using this operation, you can update application code, input configuration, and output configuration.

Updates the maintenance configuration of the Managed Service for Apache Flink application.

module Json_serializers : sig ... end
module Json_deserializers : sig ... end