Module 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.

Functions

row_to_cache_key 🔒

Type Aliases

CacheKey 🔒