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]
-
property storage
-
async read(batch_size: int | None = None, **kwargs) → List[source]
Read from buffer.
-
state_dict() → Dict[source]
Return the state of the reader as a dict.
:returns: A dict containing the reader state. At minimum, it should contain
-
load_state_dict(state_dict)[source]
