Record ¶

class Record(TypedDict, closed=True):
    event_version: NotRequired["str"]
    """<p>The version of the record format, used to track the evolution of the record structure over time.</p>"""
    created_at: NotRequired["capo_keyspacesstreams.types.date.Date"]
    """<p>The timestamp indicating when this change data capture record was created.</p>"""
    origin: NotRequired["capo_keyspacesstreams.types.origin_type.OriginType"]
    """<p>The origin or source of this change data capture record.</p>"""
    partition_keys: NotRequired[
        "capo_keyspacesstreams.types.keyspaces_keys_map.KeyspacesKeysMap"
    ]
    """<p>The partition key columns and their values for the affected row.</p>"""
    clustering_keys: NotRequired[
        "capo_keyspacesstreams.types.keyspaces_keys_map.KeyspacesKeysMap"
    ]
    """<p>The clustering key columns and their values for the affected row, which determine the order of rows within a partition.</p>"""
    new_image: NotRequired["capo_keyspacesstreams.types.keyspaces_row.KeyspacesRow"]
    """<p>The state of the row after the change operation that generated this record.</p>"""
    old_image: NotRequired["capo_keyspacesstreams.types.keyspaces_row.KeyspacesRow"]
    """<p>The state of the row before the change operation that generated this record.</p>"""
    sequence_number: NotRequired[
        "capo_keyspacesstreams.types.sequence_number.SequenceNumber"
    ]
    """<p>A unique identifier assigned to this record within the shard, used for ordering and tracking purposes.</p>"""