Values.InputDescriptionSourceDescribes the application input configuration for a SQL-based Kinesis Data Analytics application.
type nonrec t = {inputId : Id.t 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.
*)namePrefix : InAppStreamName.t option;The in-application name prefix.
*)inAppStreamNames : InAppStreamNames.t option;Returns the in-application stream names that are mapped to the stream source.
*)inputProcessingConfigurationDescription : InputProcessingConfigurationDescription.t
option;The description of the preprocessor that executes on records in this input before the application's code is run.
*)kinesisStreamsInputDescription : KinesisStreamsInputDescription.t option;If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource Name (ARN).
*)kinesisFirehoseInputDescription : KinesisFirehoseInputDescription.t option;If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN.
*)inputSchema : SourceSchema.t 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.
*)inputParallelism : InputParallelism.t option;Describes the configured parallelism (number of in-application streams mapped to the streaming source).
*)inputStartingPositionConfiguration : InputStartingPositionConfiguration.t
option;The point at which the application is configured to read from the input stream.
*)}val make :
?inputId:??? ->
?namePrefix:??? ->
?inAppStreamNames:??? ->
?inputProcessingConfigurationDescription:??? ->
?kinesisStreamsInputDescription:??? ->
?kinesisFirehoseInputDescription:??? ->
?inputSchema:??? ->
?inputParallelism:??? ->
?inputStartingPositionConfiguration:??? ->
unit ->
tval to_value :
t ->
[> `Structure of
(string
* [> `List of [> `String of InAppStreamName.t ] list
| `String of Id.t
| `Structure of
(string
* [> `Enum of string
| `Integer of InputParallelismCount.t
| `List of
[> `Structure of
(string * [> `String of RecordColumnName.t ]) list ]
list
| `String of ResourceARN.t
| `Structure of
(string
* [> `Enum of string
| `String of ResourceARN.t
| `Structure of
(string
* [> `Structure of
(string * [> `String of RecordRowPath.t ]) list ])
list ])
list ])
list ])
list ]