Skip to content

SourceSchema

Source code in docs_src/capo_kinesis_analytics/types/source_schema.py 
15
16
17
18
19
20
21
22
23
class SourceSchema(TypedDict, closed=True):
    record_format: "capo_kinesis_analytics.types.record_format.RecordFormat"
    """<p>Specifies the format of the records on the streaming source.</p>"""
    record_encoding: 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_columns: "capo_kinesis_analytics.types.record_columns.RecordColumns"
    """<p>A list of <code>RecordColumn</code> objects.</p>"""

record_columns instance-attribute 

record_columns: RecordColumns

A list of RecordColumn objects.

record_encoding instance-attribute 

record_encoding: NotRequired[RecordEncoding]

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

record_format instance-attribute 

record_format: RecordFormat

Specifies the format of the records on the streaming source.