Smaws_Client_KinesisAnalytics (smaws-clients.Smaws_Client

module Types : sig ... end

val make_update_application_response : unit -> unit

val make_input_lambda_processor_update : 
  ?role_arn_update:Types.role_ar_n ->
  ?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 : 
  ?role_arn_update:Types.role_ar_n ->
  ?resource_arn_update:Types.resource_ar_n ->
  unit ->
  Types.kinesis_streams_input_update

val make_kinesis_firehose_input_update : 
  ?role_arn_update:Types.role_ar_n ->
  ?resource_arn_update:Types.resource_ar_n ->
  unit ->
  Types.kinesis_firehose_input_update

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_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 : 
  ?role_arn_update:Types.role_ar_n ->
  ?resource_arn_update:Types.resource_ar_n ->
  unit ->
  Types.kinesis_streams_output_update

val make_kinesis_firehose_output_update : 
  ?role_arn_update:Types.role_ar_n ->
  ?resource_arn_update:Types.resource_ar_n ->
  unit ->
  Types.kinesis_firehose_output_update

val make_lambda_output_update : 
  ?role_arn_update:Types.role_ar_n ->
  ?resource_arn_update:Types.resource_ar_n ->
  unit ->
  Types.lambda_output_update

val make_destination_schema : 
  record_format_type:Types.record_format_type ->
  unit ->
  Types.destination_schema

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 : 
  ?reference_role_arn_update:Types.role_ar_n ->
  ?file_key_update:Types.file_key ->
  ?bucket_arn_update:Types.bucket_ar_n ->
  unit ->
  Types.s3_reference_data_source_update

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_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_cloud_watch_logging_option_update : 
  ?role_arn_update:Types.role_ar_n ->
  ?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_application_update : 
  ?cloud_watch_logging_option_updates:Types.cloud_watch_logging_option_updates ->
  ?reference_data_source_updates:Types.reference_data_source_updates ->
  ?output_updates:Types.output_updates ->
  ?application_code_update:Types.application_code ->
  ?input_updates:Types.input_updates ->
  unit ->
  Types.application_update

val make_update_application_request : 
  application_update:Types.application_update ->
  current_application_version_id:Types.application_version_id ->
  application_name:Types.application_name ->
  unit ->
  Types.update_application_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 : unit -> unit

val make_stop_application_request : 
  application_name:Types.application_name ->
  unit ->
  Types.stop_application_request

val make_start_application_response : unit -> unit

val make_input_starting_position_configuration : 
  ?input_starting_position:Types.input_starting_position ->
  unit ->
  Types.input_starting_position_configuration

val make_input_configuration : 
  input_starting_position_configuration:
    Types.input_starting_position_configuration ->
  id:Types.id ->
  unit ->
  Types.input_configuration

val make_start_application_request : 
  input_configurations:Types.input_configurations ->
  application_name:Types.application_name ->
  unit ->
  Types.start_application_request

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_s3_reference_data_source : 
  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

val make_s3_configuration : 
  file_key:Types.file_key ->
  bucket_ar_n:Types.bucket_ar_n ->
  role_ar_n:Types.role_ar_n ->
  unit ->
  Types.s3_configuration

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_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_kinesis_streams_output : 
  role_ar_n:Types.role_ar_n ->
  resource_ar_n:Types.resource_ar_n ->
  unit ->
  Types.kinesis_streams_output

val make_kinesis_firehose_output : 
  role_ar_n:Types.role_ar_n ->
  resource_ar_n:Types.resource_ar_n ->
  unit ->
  Types.kinesis_firehose_output

val make_lambda_output : 
  role_ar_n:Types.role_ar_n ->
  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_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_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_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_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 : 
  has_more_applications:Types.boolean_object ->
  application_summaries:Types.application_summaries ->
  unit ->
  Types.list_applications_response

val make_list_applications_request : 
  ?exclusive_start_application_name:Types.application_name ->
  ?limit:Types.list_applications_input_limit ->
  unit ->
  Types.list_applications_request

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_streams_input : 
  role_ar_n:Types.role_ar_n ->
  resource_ar_n:Types.resource_ar_n ->
  unit ->
  Types.kinesis_streams_input

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_kinesis_firehose_input : 
  role_ar_n:Types.role_ar_n ->
  resource_ar_n:Types.resource_ar_n ->
  unit ->
  Types.kinesis_firehose_input

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_input_lambda_processor : 
  role_ar_n:Types.role_ar_n ->
  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_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 ->
  ?role_ar_n:Types.role_ar_n ->
  ?resource_ar_n:Types.resource_ar_n ->
  unit ->
  Types.discover_input_schema_request

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_input_parallelism : 
  ?count:Types.input_parallelism_count ->
  unit ->
  Types.input_parallelism

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_cloud_watch_logging_option_description : 
  ?cloud_watch_logging_option_id:Types.id ->
  role_ar_n:Types.role_ar_n ->
  log_stream_ar_n:Types.log_stream_ar_n ->
  unit ->
  Types.cloud_watch_logging_option_description

val make_application_detail : 
  ?application_code:Types.application_code ->
  ?cloud_watch_logging_option_descriptions:
    Types.cloud_watch_logging_option_descriptions ->
  ?reference_data_source_descriptions:Types.reference_data_source_descriptions ->
  ?output_descriptions:Types.output_descriptions ->
  ?input_descriptions:Types.input_descriptions ->
  ?last_update_timestamp:Types.timestamp ->
  ?create_timestamp:Types.timestamp ->
  ?application_description:Types.application_description ->
  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_detail

val make_describe_application_response : 
  application_detail:Types.application_detail ->
  unit ->
  Types.describe_application_response

val make_describe_application_request : 
  application_name:Types.application_name ->
  unit ->
  Types.describe_application_request

val make_delete_application_reference_data_source_response : unit -> unit

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 : unit -> unit

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 : 
  unit ->
  unit

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 : unit -> unit

val make_delete_application_cloud_watch_logging_option_request : 
  cloud_watch_logging_option_id:Types.id ->
  current_application_version_id:Types.application_version_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_response : 
  application_summary:Types.application_summary ->
  unit ->
  Types.create_application_response

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_cloud_watch_logging_option : 
  role_ar_n:Types.role_ar_n ->
  log_stream_ar_n:Types.log_stream_ar_n ->
  unit ->
  Types.cloud_watch_logging_option

val make_create_application_request : 
  ?tags:Types.tags ->
  ?application_code:Types.application_code ->
  ?cloud_watch_logging_options:Types.cloud_watch_logging_options ->
  ?outputs:Types.outputs ->
  ?inputs:Types.inputs ->
  ?application_description:Types.application_description ->
  application_name:Types.application_name ->
  unit ->
  Types.create_application_request

val make_add_application_reference_data_source_response : unit -> unit

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 : unit -> unit

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 : unit -> unit

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 : unit -> unit

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 : unit -> unit

val make_add_application_cloud_watch_logging_option_request : 
  cloud_watch_logging_option:Types.cloud_watch_logging_option ->
  current_application_version_id:Types.application_version_id ->
  application_name:Types.application_name ->
  unit ->
  Types.add_application_cloud_watch_logging_option_request

Operations

module AddApplicationCloudWatchLoggingOption : sig ... end