Skip to content

memory

sqllocks_spindle.engine.sinks.memory

Classes

MemorySink

Accumulates all chunks in memory as DataFrames.

Not thread-safe. Each MemorySink instance should receive write_chunk() calls from a single thread. Safe for use with SinkRegistry since the registry calls each sink once per chunk dispatch.

Methods:
result()

Return all accumulated data as one DataFrame per table.