Skip to content

PartitionSpec

Source code in docs_src/capo_kafka/types/partition_spec.py 
12
13
14
15
16
17
18
19
20
class PartitionSpec(TypedDict, closed=True):
    partition_strategy: NotRequired[
        "capo_kafka.types.partition_strategy.PartitionStrategy"
    ]
    """<p>The partitioning strategy applied to records written to the table.</p>"""
    source_list: NotRequired[
        "capo_kafka.types.__list_of_partition_source.__listOfPartitionSource"
    ]
    """<p>The source columns used by the partitioning strategy. For TIME_HOUR, must contain exactly one source column whose value is a timestamp.</p>"""

partition_strategy instance-attribute 

partition_strategy: NotRequired[PartitionStrategy]

The partitioning strategy applied to records written to the table.

source_list instance-attribute 

source_list: NotRequired[__listOfPartitionSource]

The source columns used by the partitioning strategy. For TIME_HOUR, must contain exactly one source column whose value is a timestamp.