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.

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.
• row_to_cache_key 🔒

Type Aliases

• CacheKey 🔒