fraudtwin.OutputSink#

class fraudtwin.OutputSink(*args, **kwargs)[source][source]#

Bases: Protocol

Port for a chunk-aware output adapter.

write(records, *, run_id)[source][source]#

Persist a bounded batch and return checkpoint metadata.

Return type:

Mapping[str, Any]

Parameters:

  • records (Iterable[Mapping[str, Any]])

  • run_id (str)