trinity.buffer.reader.sql_reader module

trinity.buffer.reader.sql_reader module#

Reader of the SQL buffer.

class trinity.buffer.reader.sql_reader.SQLReader(config: StorageConfig)[source]#

Bases: BufferReader

Reader of the SQL buffer.

__init__(config: StorageConfig) → None[source]#
read(batch_size: int | None = None) → List[source]#

Read from buffer.

async read_async(batch_size: int | None = None) → List[source]#

Read from buffer asynchronously.

Contents