bytewax.connectors.stdio#

Connectors to console IO.

Classes#

class StdOutSink#
Bases:

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(
worker_index: int,
worker_count: int,
) bytewax.connectors.stdio._PrintSinkPartition#

See ABC docstring.

Join our community Slack channel

Need some help? Join our community!

If you have any trouble with the process or have ideas about how to improve this document, come talk to us in the #questions-answered Slack channel!

Join now