Module eowc

Modules

sort 🔒

sort_buffer 🔒

Structs

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