trinity.buffer.reader.sql_reader module

Reader of the SQL buffer.

class trinity.buffer.reader.sql_reader.SQLReader(meta: StorageConfig, config: BufferConfig)[source]

Bases: BufferReader

Reader of the SQL buffer.

__init__(meta: StorageConfig, config: BufferConfig) → None[source]
read(batch_size: int | None = None, strategy: ReadStrategy | None = None) → List[source]

Read from buffer.

async read_async(batch_size: int | None = None, strategy: ReadStrategy | None = None) → List[source]

Read from buffer asynchronously.