Module eowc 

Modules

buffer_table_cache 🔒

eowc_gap_fill 🔒

sort 🔒

sort_buffer 🔒

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.

EowcGapFillExecutor

EowcGapFillExecutorArgs

SortBuffer

SortBuffer is a common component that consume an unordered stream and produce an ordered stream by watermark. This component maintains a buffer table passed in, whose schema is same as SortBuffer’s input and output. Generally, the component acts as a buffer that output the data it received with a delay, commonly used to implement emit-on-window-close policy.

SortExecutor

SortExecutorArgs