Custom IO Connectors

More documentation here is forthcoming.

For now look at bytewax.inputs.FixedPartitionedSource and bytewax.inputs.DynamicSource for inputs and bytewax.outputs.FixedPartitionedSink and bytewax.outputs.DynamicSink for outputs for the abstract base classes you need to implement.

Also check out some of our built-in custom connectors in bytewax.connectors and looking at the source for how they are implemented.