Class BudgetPlan

crates/kernel/src/shard.rs:1785–1808

A partition sized to a per-shard Zisk **cycle** budget (rather than a fixed shard count). See [`partition_for_cycle_cap`].

  }
  let size = |b: u32| profile.block(b).serialized_size;
  let (crow, ccol) = profile.consumers_csr();
  let consumers = |b: u32| &ccol[crow[b as usize]..crow[b as usize + 1]];

  let mut owned = vec![0.0f64; num_shards];
  for b in 0..n {
    owned[shard_of[b] as usize] += static_owned_weight(size(b as u32));
  }
  // fcnt[k][p] = number of k-owned consumers of foreign producer p;
  // fbytes[k] = Σ size(p) over k's frontier (fcnt keys).
  let mut fcnt: Vec<FxHashMap<u32, u32>> =
    vec![FxHashMap::default(); num_shards];
  let mut fbytes = vec![0.0f64; num_shards];
  for c in 0..n as u32 {
    let kc = shard_of[c as usize];
    for &p in profile.producers(c) {
      if shard_of[p as usize] != kc {
        let e = fcnt[kc as usize].entry(p).or_insert(0);
        if *e == 0 {
          fbytes[kc as usize] += f64::from(size(p));
        }
        *e += 1;
      }
    }
  }

  let mut moves = 0usize;
  loop {