Module stream_sync_log_store 

Structs

EnsureSyncLogStoreFragmentRootRewriter 🔒

Insert no-shuffle exchanges above sync log stores that are not already separated by an exchange.

StreamSyncLogStore

Functions

ensure_sync_log_store_fragment_root 🔒

Run after the final stream job root is created, so physical explain and graph building see the same sync log store fragment boundary.