Output Sink

Sink is a runtime platform component responsible for consuming the pipeline produced output.

forml.lib.sink.stdout

Stdout writer sink implementation.

API

class forml.io.sink.Provider(*args, **kwargs)[source]

Sink is an implementation of a specific data consumer.

Return type

Interface

class Writer(**kwargs)[source]

Abstract sink writer.

publish()[source]

Provide a pipeline composable segment implementing the publish action.

Returns

Pipeline segment.

Return type

forml.flow.pipeline.Segment

classmethod writer(**kwargs)[source]

Return the reader instance of this feed (any callable, presumably extract.Reader).

Parameters

kwargs (Any) – Optional writer keyword arguments.

Returns

Writer instance.

Return type

Callable[[Sequence[Any]], None]