Skip to content

Commit 603ccc6

Browse files
committed
add docs for backfill orders
1 parent 5543490 commit 603ccc6

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

src/meta/model/src/streaming_job.rs

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,15 @@ pub struct Model {
3333
pub specific_resource_group: Option<String>,
3434
}
3535

36+
/// This data structure contains an adjacency list of
37+
/// backfill nodes.
38+
/// Each edge represents a backfill order.
39+
/// For instance, given:
40+
/// `BackfillOrders[1] = [2, 3, 4]`
41+
/// It means that node 1 must be backfilled before nodes 2, 3, and 4.
42+
/// Concretely, these node ids are the fragment ids.
43+
/// This is because each fragment will only have 1 stream scan,
44+
/// and stream scan corresponds to a backfill node.
3645
#[derive(Clone, Debug, PartialEq, Eq, FromJsonQueryResult, Serialize, Deserialize, Default)]
3746
pub struct BackfillOrders(pub HashMap<u32, Vec<u32>>);
3847

0 commit comments

Comments
 (0)