faust.joins

Join strategies.

class faust.joins.Join(*, stream: JoinableT, fields: Tuple[FieldDescriptorT, ...])

Base class for join strategies.

async process(event: EventT) → Optional[EventT]

Process event to be joined with another event.

Return type:

_UnionGenericAlias[EventT, None]

class faust.joins.RightJoin(*, stream: JoinableT, fields: Tuple[FieldDescriptorT, ...])

Right-join strategy.

class faust.joins.LeftJoin(*, stream: JoinableT, fields: Tuple[FieldDescriptorT, ...])

Left-join strategy.

class faust.joins.InnerJoin(*, stream: JoinableT, fields: Tuple[FieldDescriptorT, ...])

Inner-join strategy.

class faust.joins.OuterJoin(*, stream: JoinableT, fields: Tuple[FieldDescriptorT, ...])

Outer-join strategy.