Skip to content

InputSchemaUpdate

Source code in docs_src/capo_kinesis_analytics/types/input_schema_update.py 
13
14
15
16
17
18
19
20
21
22
23
24
25
class InputSchemaUpdate(TypedDict, closed=True):
    record_format_update: NotRequired[
        "capo_kinesis_analytics.types.record_format.RecordFormat"
    ]
    """<p>Specifies the format of the records on the streaming source.</p>"""
    record_encoding_update: NotRequired[
        "capo_kinesis_analytics.types.record_encoding.RecordEncoding"
    ]
    """<p>Specifies the encoding of the records in the streaming source. For example, UTF-8.</p>"""
    record_column_updates: NotRequired[
        "capo_kinesis_analytics.types.record_columns.RecordColumns"
    ]
    """<p>A list of <code>RecordColumn</code> objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream. </p>"""

record_column_updates instance-attribute 

record_column_updates: NotRequired[RecordColumns]

A list of RecordColumn objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.

record_encoding_update instance-attribute 

record_encoding_update: NotRequired[RecordEncoding]

Specifies the encoding of the records in the streaming source. For example, UTF-8.

record_format_update instance-attribute 

record_format_update: NotRequired[RecordFormat]

Specifies the format of the records on the streaming source.