Module independent_job 

Modules

batch_refresh_job 🔒

Batch refresh job checkpoint control for periodically-refreshed materialized views.

creating_job 🔒

iceberg_v3_job 🔒

Structs

IndependentJobControl 🔒

IndependentJobInfo 🔒

InitialPartialGraphRequest 🔒

SnapshotPhaseControl 🔒

Enums

IndependentCheckpointJob 🔒

The type-specific running state of a streaming job that checkpoints independently from the database’s main graph.

IndependentCheckpointJobControl 🔒

The lifecycle shared by all independent checkpoint jobs.

IndependentCheckpointJobStatus 🔒

Functions

add_initial_partial_graph 🔒

build_initial_add_mutation 🔒

new_fake_barrier 🔒

Build a fake BarrierInfo for independent partial-graph barriers.

snapshot_backfill_max_pending_barrier_num 🔒