flow.record.adapter.duckdb

Module Contents

Classes

DuckdbReader	DuckDB reader, subclasses from SQLite reader.
DuckdbWriter	DuckDB writer, subclasses from SQLite writer.

Attributes

logger
__usage__

flow.record.adapter.duckdb.logger

flow.record.adapter.duckdb.__usage__ = Multiline-String

Show Value

"""
DuckDB adapter
---
Write usage: rdump -w duckdb://[PATH]?batch_size=[BATCH_SIZE]
Read usage: rdump duckdb://[PATH]?batch_size=[BATCH_SIZE]
[PATH]: path to DuckDB database file

Optional parameters:
    [BATCH_SIZE]: number of records to read or write in a single transaction (default: 1000)
"""

class flow.record.adapter.duckdb.DuckdbReader(path: str, *, batch_size: str | int = 1000, selector: flow.record.adapter.sqlite.Selector | str | None = None, **kwargs)

Bases: flow.record.adapter.sqlite.SqliteReader

DuckDB reader, subclasses from SQLite reader.

logger

class flow.record.adapter.duckdb.DuckdbWriter(path: str, *, batch_size: str | int = 1000, **kwargs)

Bases: flow.record.adapter.sqlite.SqliteWriter

DuckDB writer, subclasses from SQLite writer.

logger

tx_cycle() → None