Module decouple_checkpoint_log_sink

Structs

DecoupleCheckpointLogSinkerOf

The LogSinker implementation used for commit-decoupled sinks (such as Iceberg, DeltaLake and StarRocks). The concurrent/frequent commit capability of these sinks is poor, so by leveraging the decoupled log reader, we delay the checkpoint barrier to make commits less frequent.

Constants

COMMIT_CHECKPOINT_INTERVAL

DEFAULT_COMMIT_CHECKPOINT_INTERVAL_WITHOUT_SINK_DECOUPLE

DEFAULT_COMMIT_CHECKPOINT_INTERVAL_WITH_SINK_DECOUPLE

Functions

default_commit_checkpoint_interval