bytewax.connectors.stdio

Connectors to console IO.

Classes

class StdOutSink

Bases:

• DynamicSink[Any]

Write each output item to stdout on that worker.

Items consumed from the dataflow must look like a string. Use a proceeding map step to do custom formatting.

Workers are the unit of parallelism.

Can support at-least-once processing. Messages from the resume epoch will be duplicated right after resume.

build(

_step_id: str,

_worker_index: int,

_worker_count: int,

) → bytewax.connectors.stdio._PrintSinkPartition