Module eowc 

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 🔒

PartitionProgress 🔒

Output progress of a partition, persisted in the progress column of the intermediate state table.

Constants

LOAD_CONCURRENCY 🔒

Number of partitions loaded concurrently.

Functions

decode_progress 🔒

decode_snapshot 🔒

Decode a WindowStateSnapshot from bytes during recovery using protobuf.

decode_state_key 🔒

encode_progress 🔒

Encode a PartitionProgress for persistence, or None if it’s empty.

encode_snapshot 🔒

Encode a WindowStateSnapshot to bytes for persistence using protobuf.

encode_state_key 🔒

Type Aliases

PartitionCache 🔒