Values.DiscoverInputSchemaResponseSourcetype nonrec t = {inputSchema : SourceSchema.t option;Schema inferred from the streaming source. It identifies the format of the data in the streaming source and how each data element maps to corresponding columns in the in-application stream that you can create.
*)parsedInputRecords : ParsedInputRecords.t option;An array of elements, where each element corresponds to a row in a stream record (a stream record can have more than one row).
*)processedInputRecords : ProcessedInputRecords.t option;Stream data that was modified by the processor specified in the InputProcessingConfiguration parameter.
*)rawInputRecords : RawInputRecords.t option;Raw stream data that was sampled to infer the schema.
*)}type nonrec error = [ | `InvalidArgumentException of InvalidArgumentException.t| `ResourceProvisionedThroughputExceededException of
ResourceProvisionedThroughputExceededException.t| `UnableToDetectSchemaException of UnableToDetectSchemaException.t| `Unknown_operation_error of string * string option ]val error_of_json :
string ->
Yojson.Safe.t ->
[> `InvalidArgumentException of InvalidArgumentException.t
| `ResourceProvisionedThroughputExceededException of
ResourceProvisionedThroughputExceededException.t
| `ServiceUnavailableException of ServiceUnavailableException.t
| `UnableToDetectSchemaException of UnableToDetectSchemaException.t
| `Unknown_operation_error of string * string option ]val error_of_xml :
string ->
Awso.Xml.t ->
[> `InvalidArgumentException of InvalidArgumentException.t
| `ResourceProvisionedThroughputExceededException of
ResourceProvisionedThroughputExceededException.t
| `ServiceUnavailableException of ServiceUnavailableException.t
| `UnableToDetectSchemaException of UnableToDetectSchemaException.t
| `Unknown_operation_error of string * string option ]val to_value :
t ->
[> `Structure of
(string
* [> `List of
[> `List of [> `String of ParsedInputRecordField.t ] list
| `String of ProcessedInputRecord.t ]
list
| `Structure of
(string
* [> `List of
[> `Structure of
(string * [> `String of RecordColumnName.t ]) list ]
list
| `String of RecordEncoding.t
| `Structure of
(string
* [> `Enum of string
| `Structure of
(string
* [> `Structure of
(string * [> `String of RecordRowPath.t ]) list ])
list ])
list ])
list ])
list ]