Module eowc

risingwave_stream::executor::over_window

Module eowc 

Source

Structs§

EowcOverWindowExecutor
EowcOverWindowExecutor consumes ordered input (on order key column with watermark in ascending order) and outputs window function results. One EowcOverWindowExecutor can handle one combination of partition key and order key.
EowcOverWindowExecutorArgs
ExecutionVars 🔒
ExecutorInner 🔒
Partition 🔒

Functions§

decode_snapshot 🔒
Decode a WindowStateSnapshot from bytes during recovery using protobuf.
encode_snapshot 🔒
Encode a WindowStateSnapshot to bytes for persistence using protobuf.

Type Aliases§

PartitionCache 🔒