listener

superduper.components.listener

Source code

Listener

Listener(self,
     identifier: str,
     upstream: Optional[List[ForwardRef('Component')]] = None,
     db: dataclasses.InitVar[typing.Optional[ForwardRef('Datalayer')]] = None,
     *,
     cdc_table: str = '',
     key: superduper.misc.typing.JSON,
     model: superduper.components.model.Model,
     predict_kwargs: Optional[Dict] = <factory>,
     select: Optional[superduper.base.query.Query] = None,
     flatten: bool = False) -> None

Parameter	Description
identifier	Identifier of the instance.
upstream	A list of upstream components.
db	Datalayer instance. Datalayer instance.
cdc_table	Table which fires the triggers.
key	Key to be bound to the model.
model	Model for processing data.
predict_kwargs	Keyword arguments to self.model.predict().
select	Query to "listen" for input on.
flatten	Flatten the output into separate records if True.

Listener component.

Listener object which is used to process a column/key of a collection or table, and store the outputs.