Module Values.InputUpdateSource

For a SQL-based Kinesis Data Analytics application, describes updates to a specific input configuration (identified by the InputId of an application).

Sourcetype nonrec t = {
  1. inputId : Id.t;
    (*

    The input ID of the application input to be updated.

    *)
  2. namePrefixUpdate : InAppStreamName.t option;
    (*

    The name prefix for in-application streams that Kinesis Data Analytics creates for the specific streaming source.

    *)
  3. inputProcessingConfigurationUpdate : InputProcessingConfigurationUpdate.t option;
    (*

    Describes updates to an InputProcessingConfiguration.

    *)
  4. kinesisStreamsInputUpdate : KinesisStreamsInputUpdate.t option;
    (*

    If a Kinesis data stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN).

    *)
  5. kinesisFirehoseInputUpdate : KinesisFirehoseInputUpdate.t option;
    (*

    If a Kinesis Data Firehose delivery stream is the streaming source to be updated, provides an updated stream ARN.

    *)
  6. inputSchemaUpdate : InputSchemaUpdate.t option;
    (*

    Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.

    *)
  7. inputParallelismUpdate : InputParallelismUpdate.t option;
    (*

    Describes the parallelism updates (the number of in-application streams Kinesis Data Analytics creates for the specific streaming source).

    *)
}
Sourceval context_ : string
Sourceval make : ?namePrefixUpdate:??? -> ?inputProcessingConfigurationUpdate:??? -> ?kinesisStreamsInputUpdate:??? -> ?kinesisFirehoseInputUpdate:??? -> ?inputSchemaUpdate:??? -> ?inputParallelismUpdate:??? -> inputId:Id.t -> unit -> t
Sourceval to_value : t -> [> `Structure of (string * [> `String of Id.t | `Structure 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 ]
Sourceval to_query : t -> Awso.Client.Query.t
Sourceval of_xml : Awso.Xml.t -> t
Sourceval of_string : string -> t
Sourceval of_json : Yojson.Safe.t -> t
Sourceval to_json : t -> Yojson.Safe.t