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