faust.assignor.client_assignment
¶
Client Assignment.
-
class
faust.assignor.client_assignment.
CopartitionedAssignment
(actives: Set[int] = None, standbys: Set[int] = None, topics: Set[str] = None) → None[source]¶ Copartitioned Assignment.
-
class
faust.assignor.client_assignment.
ClientAssignment
(actives, standbys, *, __strict__=True, __faust=None, **kwargs) → None[source]¶ Client Assignment data model.
-
actives
¶ Describes a field.
Used for every field in Record so that they can be used in join’s /group_by etc.
Examples
>>> class Withdrawal(Record): ... account_id: str ... amount: float = 0.0
>>> Withdrawal.account_id <FieldDescriptor: Withdrawal.account_id: str> >>> Withdrawal.amount <FieldDescriptor: Withdrawal.amount: float = 0.0>
- Parameters
- Keyword Arguments
model (Type) – Model class the field belongs to.
parent (FieldDescriptorT) – parent field if any.
-
standbys
¶ Describes a field.
Used for every field in Record so that they can be used in join’s /group_by etc.
Examples
>>> class Withdrawal(Record): ... account_id: str ... amount: float = 0.0
>>> Withdrawal.account_id <FieldDescriptor: Withdrawal.account_id: str> >>> Withdrawal.amount <FieldDescriptor: Withdrawal.amount: float = 0.0>
- Parameters
- Keyword Arguments
model (Type) – Model class the field belongs to.
parent (FieldDescriptorT) – parent field if any.
-
kafka_protocol_assignment
(table_manager: faust.types.tables.TableManagerT) → Sequence[Tuple[str, List[int]]][source]¶
-
add_copartitioned_assignment
(assignment: faust.assignor.client_assignment.CopartitionedAssignment) → None[source]¶ - Return type
None
-
copartitioned_assignment
(topics: Set[str]) → faust.assignor.client_assignment.CopartitionedAssignment[source]¶ - Return type
-
asdict
()¶
-
-
class
faust.assignor.client_assignment.
ClientMetadata
(assignment, url, changelog_distribution, topic_groups=None, *, __strict__=True, __faust=None, **kwargs) → None[source]¶ Client Metadata data model.
-
assignment
¶ Describes a field.
Used for every field in Record so that they can be used in join’s /group_by etc.
Examples
>>> class Withdrawal(Record): ... account_id: str ... amount: float = 0.0
>>> Withdrawal.account_id <FieldDescriptor: Withdrawal.account_id: str> >>> Withdrawal.amount <FieldDescriptor: Withdrawal.amount: float = 0.0>
- Parameters
- Keyword Arguments
model (Type) – Model class the field belongs to.
parent (FieldDescriptorT) – parent field if any.
-
url
¶
-
asdict
()¶
-
changelog_distribution
¶ Describes a field.
Used for every field in Record so that they can be used in join’s /group_by etc.
Examples
>>> class Withdrawal(Record): ... account_id: str ... amount: float = 0.0
>>> Withdrawal.account_id <FieldDescriptor: Withdrawal.account_id: str> >>> Withdrawal.amount <FieldDescriptor: Withdrawal.amount: float = 0.0>
- Parameters
- Keyword Arguments
model (Type) – Model class the field belongs to.
parent (FieldDescriptorT) – parent field if any.
-
topic_groups
¶
-