KinesisAnalyticsV2.Application
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kinesisanalyticsv2-application.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-kinesisfirehoseinput.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-resource-tags.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-applicationsnapshotconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-gluedatacatalogconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-applicationrestoreconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-inputlambdaprocessor.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-applicationmaintenanceconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-monitoringconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-zeppelinmonitoringconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-inputparallelism.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-s3contentlocation.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-csvmappingparameters.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-kinesisstreamsinput.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-flinkrunconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-recordcolumn.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-mavenreference.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-vpcconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-propertygroup.html
and parallelism_configuration = {
configuration_type : string;
parallelism_per_kpu : int option;
auto_scaling_enabled : bool option;
parallelism : int option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-parallelismconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-s3contentbaselocation.html
and checkpoint_configuration = {
configuration_type : string;
checkpoint_interval : int option;
min_pause_between_checkpoints : int option;
checkpointing_enabled : bool option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-checkpointconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-jsonmappingparameters.html
and run_configuration = {
flink_run_configuration : flink_run_configuration option;
application_restore_configuration : application_restore_configuration option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-runconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-inputprocessingconfiguration.html
and custom_artifact_configuration = {
maven_reference : maven_reference option;
s3_content_location : s3_content_location option;
artifact_type : string;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-customartifactconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-environmentproperties.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-kinesisanalyticsv2-application-mappingparameters.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-deployasapplicationconfiguration.html
and code_content = {
zip_file_content : string option;
s3_content_location : s3_content_location option;
text_content : string option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-codecontent.html
and catalog_configuration = {
glue_data_catalog_configuration : glue_data_catalog_configuration option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-catalogconfiguration.html
and flink_application_configuration = {
checkpoint_configuration : checkpoint_configuration option;
parallelism_configuration : parallelism_configuration option;
monitoring_configuration : monitoring_configuration option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-flinkapplicationconfiguration.html
and zeppelin_application_configuration = {
catalog_configuration : catalog_configuration option;
monitoring_configuration : zeppelin_monitoring_configuration option;
deploy_as_application_configuration : deploy_as_application_configuration
option;
custom_artifacts_configuration : custom_artifact_configuration list option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-zeppelinapplicationconfiguration.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-recordformat.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-applicationcodeconfiguration.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-kinesisanalyticsv2-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-kinesisanalyticsv2-application-input.html
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-sqlapplicationconfiguration.html
and application_configuration = {
application_code_configuration : application_code_configuration option;
environment_properties : environment_properties option;
flink_application_configuration : flink_application_configuration option;
sql_application_configuration : sql_application_configuration option;
zeppelin_application_configuration : zeppelin_application_configuration option;
vpc_configurations : vpc_configuration list option;
application_snapshot_configuration : application_snapshot_configuration option;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisanalyticsv2-application-applicationconfiguration.html
type properties = {
application_name : string option;
runtime_environment : string;
run_configuration : run_configuration option;
application_mode : string option;
application_maintenance_configuration : application_maintenance_configuration
option;
application_configuration : application_configuration option;
application_description : string option;
service_execution_role : string;
}
see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kinesisanalyticsv2-application.html;
val make_properties :
?application_name:string ->
runtime_environment:string ->
?run_configuration:run_configuration ->
?application_mode:string ->
?application_maintenance_configuration:application_maintenance_configuration ->
?application_configuration:application_configuration ->
?application_description:string ->
?tags:tag list ->
service_execution_role:string ->
unit ->
properties
val make_kinesis_firehose_input :
resource_arn:string ->
unit ->
kinesis_firehose_input
val make_tag : value:string -> key:string -> unit -> tag
val make_application_snapshot_configuration :
snapshots_enabled:bool ->
unit ->
application_snapshot_configuration
val make_glue_data_catalog_configuration :
?database_arn:string ->
unit ->
glue_data_catalog_configuration
val make_application_restore_configuration :
?snapshot_name:string ->
application_restore_type:string ->
unit ->
application_restore_configuration
val make_input_lambda_processor :
resource_arn:string ->
unit ->
input_lambda_processor
val make_application_maintenance_configuration :
application_maintenance_window_start_time:string ->
unit ->
application_maintenance_configuration
val make_monitoring_configuration :
configuration_type:string ->
?metrics_level:string ->
?log_level:string ->
unit ->
monitoring_configuration
val make_zeppelin_monitoring_configuration :
?log_level:string ->
unit ->
zeppelin_monitoring_configuration
val make_input_parallelism : ?count:int -> unit -> input_parallelism
val make_s3_content_location :
bucket_arn:string ->
file_key:string ->
?object_version:string ->
unit ->
s3_content_location
val make_csv_mapping_parameters :
record_row_delimiter:string ->
record_column_delimiter:string ->
unit ->
csv_mapping_parameters
val make_kinesis_streams_input :
resource_arn:string ->
unit ->
kinesis_streams_input
val make_flink_run_configuration :
?allow_non_restored_state:bool ->
unit ->
flink_run_configuration
val make_record_column :
?mapping:string ->
sql_type:string ->
name:string ->
unit ->
record_column
val make_maven_reference :
artifact_id:string ->
version:string ->
group_id:string ->
unit ->
maven_reference
val make_vpc_configuration :
security_group_ids:string list ->
subnet_ids:string list ->
unit ->
vpc_configuration
val make_property_group :
?property_map:string Stdlib__Map.Make(Stdlib.String).t ->
?property_group_id:string ->
unit ->
property_group
val make_parallelism_configuration :
configuration_type:string ->
?parallelism_per_kpu:int ->
?auto_scaling_enabled:bool ->
?parallelism:int ->
unit ->
parallelism_configuration
val make_s3_content_base_location :
bucket_arn:string ->
?base_path:string ->
unit ->
s3_content_base_location
val make_checkpoint_configuration :
configuration_type:string ->
?checkpoint_interval:int ->
?min_pause_between_checkpoints:int ->
?checkpointing_enabled:bool ->
unit ->
checkpoint_configuration
val make_json_mapping_parameters :
record_row_path:string ->
unit ->
json_mapping_parameters
val make_run_configuration :
?flink_run_configuration:flink_run_configuration ->
?application_restore_configuration:application_restore_configuration ->
unit ->
run_configuration
val make_input_processing_configuration :
?input_lambda_processor:input_lambda_processor ->
unit ->
input_processing_configuration
val make_custom_artifact_configuration :
?maven_reference:maven_reference ->
?s3_content_location:s3_content_location ->
artifact_type:string ->
unit ->
custom_artifact_configuration
val make_environment_properties :
?property_groups:property_group list ->
unit ->
environment_properties
val make_mapping_parameters :
?json_mapping_parameters:json_mapping_parameters ->
?csv_mapping_parameters:csv_mapping_parameters ->
unit ->
mapping_parameters
val make_deploy_as_application_configuration :
s3_content_location:s3_content_base_location ->
unit ->
deploy_as_application_configuration
val make_code_content :
?zip_file_content:string ->
?s3_content_location:s3_content_location ->
?text_content:string ->
unit ->
code_content
val make_catalog_configuration :
?glue_data_catalog_configuration:glue_data_catalog_configuration ->
unit ->
catalog_configuration
val make_flink_application_configuration :
?checkpoint_configuration:checkpoint_configuration ->
?parallelism_configuration:parallelism_configuration ->
?monitoring_configuration:monitoring_configuration ->
unit ->
flink_application_configuration
val make_zeppelin_application_configuration :
?catalog_configuration:catalog_configuration ->
?monitoring_configuration:zeppelin_monitoring_configuration ->
?deploy_as_application_configuration:deploy_as_application_configuration ->
?custom_artifacts_configuration:custom_artifact_configuration list ->
unit ->
zeppelin_application_configuration
val make_record_format :
?mapping_parameters:mapping_parameters ->
record_format_type:string ->
unit ->
record_format
val make_application_code_configuration :
code_content_type:string ->
code_content:code_content ->
unit ->
application_code_configuration
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 make_sql_application_configuration :
?inputs:input list ->
unit ->
sql_application_configuration
val make_application_configuration :
?application_code_configuration:application_code_configuration ->
?environment_properties:environment_properties ->
?flink_application_configuration:flink_application_configuration ->
?sql_application_configuration:sql_application_configuration ->
?zeppelin_application_configuration:zeppelin_application_configuration ->
?vpc_configurations:vpc_configuration list ->
?application_snapshot_configuration:application_snapshot_configuration ->
unit ->
application_configuration
val yojson_of_kinesis_firehose_input : kinesis_firehose_input -> Yojson.Safe.t
val yojson_of_tag : tag -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_application_snapshot_configuration :
application_snapshot_configuration ->
Yojson.Safe.t
val yojson_of_glue_data_catalog_configuration :
glue_data_catalog_configuration ->
Yojson.Safe.t
val yojson_of_application_restore_configuration :
application_restore_configuration ->
Yojson.Safe.t
val yojson_of_input_lambda_processor : input_lambda_processor -> Yojson.Safe.t
val yojson_of_application_maintenance_configuration :
application_maintenance_configuration ->
[> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_monitoring_configuration :
monitoring_configuration ->
Yojson.Safe.t
val yojson_of_zeppelin_monitoring_configuration :
zeppelin_monitoring_configuration ->
Yojson.Safe.t
val yojson_of_input_parallelism : input_parallelism -> Yojson.Safe.t
val yojson_of_s3_content_location : s3_content_location -> Yojson.Safe.t
val yojson_of_csv_mapping_parameters : csv_mapping_parameters -> Yojson.Safe.t
val yojson_of_kinesis_streams_input : kinesis_streams_input -> Yojson.Safe.t
val yojson_of_flink_run_configuration :
flink_run_configuration ->
Yojson.Safe.t
val yojson_of_record_column : record_column -> Yojson.Safe.t
val yojson_of_maven_reference : maven_reference -> Yojson.Safe.t
val yojson_of_vpc_configuration : vpc_configuration -> Yojson.Safe.t
val yojson_of_property_group : property_group -> Yojson.Safe.t
val yojson_of_parallelism_configuration :
parallelism_configuration ->
Yojson.Safe.t
val yojson_of_s3_content_base_location :
s3_content_base_location ->
Yojson.Safe.t
val yojson_of_checkpoint_configuration :
checkpoint_configuration ->
Yojson.Safe.t
val yojson_of_json_mapping_parameters :
json_mapping_parameters ->
Yojson.Safe.t
val yojson_of_run_configuration :
run_configuration ->
[> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_input_processing_configuration :
input_processing_configuration ->
Yojson.Safe.t
val yojson_of_custom_artifact_configuration :
custom_artifact_configuration ->
Yojson.Safe.t
val yojson_of_environment_properties : environment_properties -> Yojson.Safe.t
val yojson_of_mapping_parameters : mapping_parameters -> Yojson.Safe.t
val yojson_of_deploy_as_application_configuration :
deploy_as_application_configuration ->
Yojson.Safe.t
val yojson_of_code_content : code_content -> Yojson.Safe.t
val yojson_of_catalog_configuration : catalog_configuration -> Yojson.Safe.t
val yojson_of_flink_application_configuration :
flink_application_configuration ->
Yojson.Safe.t
val yojson_of_zeppelin_application_configuration :
zeppelin_application_configuration ->
Yojson.Safe.t
val yojson_of_record_format : record_format -> Yojson.Safe.t
val yojson_of_application_code_configuration :
application_code_configuration ->
Yojson.Safe.t
val yojson_of_input_schema : input_schema -> Yojson.Safe.t
val yojson_of_input : input -> Yojson.Safe.t
val yojson_of_sql_application_configuration :
sql_application_configuration ->
Yojson.Safe.t
val yojson_of_application_configuration :
application_configuration ->
[> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_properties :
properties ->
[> `Assoc of (string * Yojson.Safe.t) list ]
val create_attributes : string -> attributes