Module factory 

Streaming writer factory registry and connections.

Structs

WriterConnectConfig

Connection settings handed to writer factories.

Enums

WriterBackendType

Streaming writer backend used to persist run data, mirroring CatalogBackendType.

Constants

FEATHER_WRITER_FACTORY_NAME

Built-in Feather streaming writer registry key.

PARQUET_WRITER_FACTORY_NAME

Built-in Parquet streaming writer registry key.

Functions

create_writer

Resolves a writer backend through the factory registry and constructs the writer.

replace_existing_writer_data

Deletes existing objects below writer connection URI.

Type Aliases

WriterFactory

Factory constructing a streaming writer from connection settings and a clock.

WriterFactoryRegistry

Ordered registry of writer factories keyed by name.