Values_0.DirectKinesisSourceSourceSpecifies a direct Amazon Kinesis data source.
type nonrec t = {name : NodeName.t;The name of the data source.
*)windowSize : BoxedPositiveInt.t option;The amount of time to spend processing each micro batch.
*)detectSchema : BoxedBoolean.t option;Whether to automatically determine the schema from the incoming data.
*)streamingOptions : KinesisStreamingSourceOptions.t option;Additional options for the Kinesis streaming data source.
*)dataPreviewOptions : StreamingDataPreviewOptions.t option;Additional options for data preview.
*)}val make :
?windowSize:??? ->
?detectSchema:??? ->
?streamingOptions:??? ->
?dataPreviewOptions:??? ->
name:NodeName.t ->
unit ->
tval to_value :
t ->
[> `Structure of
(string
* [> `Boolean of BoxedBoolean.t
| `Integer of BoxedPositiveInt.t
| `String of NodeName.t
| `Structure of
(string
* [> `Boolean of BoxedBoolean.t
| `Enum of string
| `Integer of BoxedNonNegativeInt.t
| `Long of BoxedNonNegativeLong.t
| `String of EnclosedInStringProperty.t
| `Timestamp of Iso8601DateTime.t ])
list ])
list ]