KinesisAnalytics.Application
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kinesisanalytics-application.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-inputlambdaprocessor.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-kinesisstreamsinput.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-csvmappingparameters.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-recordcolumn.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-inputparallelism.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-kinesisfirehoseinput.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-jsonmappingparameters.html
and mapping_parameters = {
json_mapping_parameters : json_mapping_parameters option;
csv_mapping_parameters : csv_mapping_parameters option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-mappingparameters.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-inputprocessingconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-recordformat.html
and input_schema = {
record_encoding : string option;
record_columns : record_column list;
record_format : record_format;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-inputschema.html
and input = {
name_prefix : string;
input_schema : input_schema;
kinesis_streams_input : kinesis_streams_input option;
kinesis_firehose_input : kinesis_firehose_input option;
input_processing_configuration : input_processing_configuration option;
input_parallelism : input_parallelism option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalytics-application-input.html
type properties = {
application_name : string option;
inputs : input list;
application_description : string option;
application_code : string option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kinesisanalytics-application.html;
val make_properties :
?application_name:string ->
inputs:input list ->
?application_description:string ->
?application_code:string ->
unit ->
properties
val make_input_lambda_processor :
resource_arn:string ->
role_arn:string ->
unit ->
input_lambda_processor
val make_kinesis_streams_input :
resource_arn:string ->
role_arn:string ->
unit ->
kinesis_streams_input
val make_csv_mapping_parameters :
record_row_delimiter:string ->
record_column_delimiter:string ->
unit ->
csv_mapping_parameters
val make_record_column :
?mapping:string ->
sql_type:string ->
name:string ->
unit ->
record_column
val make_input_parallelism : ?count:int -> unit -> input_parallelism
val make_kinesis_firehose_input :
resource_arn:string ->
role_arn:string ->
unit ->
kinesis_firehose_input
val make_json_mapping_parameters :
record_row_path:string ->
unit ->
json_mapping_parameters
val make_mapping_parameters :
?json_mapping_parameters:json_mapping_parameters ->
?csv_mapping_parameters:csv_mapping_parameters ->
unit ->
mapping_parameters
val make_input_processing_configuration :
?input_lambda_processor:input_lambda_processor ->
unit ->
input_processing_configuration
val make_record_format :
?mapping_parameters:mapping_parameters ->
record_format_type:string ->
unit ->
record_format
val make_input_schema :
?record_encoding:string ->
record_columns:record_column list ->
record_format:record_format ->
unit ->
input_schema
val make_input :
name_prefix:string ->
input_schema:input_schema ->
?kinesis_streams_input:kinesis_streams_input ->
?kinesis_firehose_input:kinesis_firehose_input ->
?input_processing_configuration:input_processing_configuration ->
?input_parallelism:input_parallelism ->
unit ->
input
val yojson_of_input_lambda_processor : input_lambda_processor -> Yojson.Safe.t
val yojson_of_kinesis_streams_input : kinesis_streams_input -> Yojson.Safe.t
val yojson_of_csv_mapping_parameters : csv_mapping_parameters -> Yojson.Safe.t
val yojson_of_record_column : record_column -> Yojson.Safe.t
val yojson_of_input_parallelism : input_parallelism -> Yojson.Safe.t
val yojson_of_kinesis_firehose_input : kinesis_firehose_input -> Yojson.Safe.t
val yojson_of_json_mapping_parameters :
json_mapping_parameters ->
Yojson.Safe.t
val yojson_of_mapping_parameters : mapping_parameters -> Yojson.Safe.t
val yojson_of_input_processing_configuration :
input_processing_configuration ->
Yojson.Safe.t
val yojson_of_record_format : record_format -> Yojson.Safe.t
val yojson_of_input_schema : input_schema -> Yojson.Safe.t
val yojson_of_input : input -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_properties :
properties ->
[> `Assoc of (string * Yojson.Safe.t) list ]
val create_attributes : string -> attributes