Module sink 

Structs

SinkExecutor

UpsertBehavior 🔒

When the sink is an upsert sink, we need to do some extra work for correctness and performance.

Enums

RebuildSinkMessage 🔒

Functions

force_append_only 🔒

force_delete_only 🔒