risingwave_stream::executor

Module locality_provider

Source

Structs§

LocalityBackfillState 🔒
State management for locality provider backfill process
LocalityProviderExecutor
The LocalityProviderExecutor provides locality for operators during backfilling. It buffers input data into a state table using locality columns as primary key prefix.

Enums§

LocalityBackfillProgress 🔒
Progress state for tracking backfill per vnode

Type Aliases§

Builders 🔒