Source code for faust.types.joins
import abc
from typing import MutableMapping, Optional, Tuple, Type
from .events import EventT
from .models import FieldDescriptorT, ModelT
from .streams import JoinableT
__all__ = ['JoinT']
[docs]class JoinT(abc.ABC):
fields: MutableMapping[Type[ModelT], FieldDescriptorT]
stream: JoinableT
@abc.abstractmethod
def __init__(self, *, stream: JoinableT,
fields: Tuple[FieldDescriptorT, ...]) -> None:
...
[docs] @abc.abstractmethod
async def process(self, event: EventT) -> Optional[EventT]:
...