Module buffer_table_cache 

Structs

BufferTableCache

Caches the smallest rows of a buffer table, whose rows are consumed in the pk order by watermark, so that consuming doesn’t scan the table every time. The cache key must be ordered as the pk of the table, and the writes to the table must be applied to the cache too.

Constants

CACHE_CAPACITY 🔒

Functions

key_value_to_full_row 🔒

Merge the key part and value part of a row into a full row. This is needed for state table with non-None value indices.