code wiki / (root) / nx_mrshuffle_gate.nx

nx_mrshuffle_gate.nx

buildroot/runtime/nx_mrshuffle_gate.nx

5204 B116 linesdepth 4pulls 5 transitivereach 0 importersview sourcekind gate/proof
docsdependenciesstructsconstsfunctions

about

nx_mrshuffle_gate.nx -- proves the shuffle is a CORRECT distributed dataflow: every key routes to exactly one reducer (disjoint partitioning by hash), each reducer sees all its rows, and the union of the parallel reducers equals the monolithic group-by -- for several reducer counts, with high key cardinality, under REAL forked concurrency. D001 verdict via nx_gate_verdict. expect_exit: 0 license_tier: ORIGINAL

dependencies 2 imports · 0 importers

nx_gate_verdict.nx nx_mrshuffle.nx nx_mrshuffle_gate.nx

imports: nx_gate_verdict.nxnx_mrshuffle.nx

imported by: nobody (leaf or entry point)

call flow from main pre-order; caps 40 nodes / depth 6 declared; ↻ = already shown

main gv_ctr sys_mmap gv_head gv_puts sys_write gv_check gv_puts ↻ sg_eq mr_reducer mr_hash sg_frame2 cf_encoded_bytes cf_slen cf_align8 cf_encode cf_align8 ↻ sys_mmap_shared mr_groupby_shuffle cf_nrows cf_col cf_data_off sys_mmap ↻ mr_reducer ↻ sys_mmap_shared ↻ sys_fork sys_exit sys_wait4 gv_verdict gv_puts ↻ gv_num sys_mmap ↻ sys_write ↻ sys_munmap gv_journal sys_openat_append sys_mmap ↻ gv_catn sys_mmap ↻ sys_munmap ↻

structs

none

consts

none

functions

8func sg_eq(a: i64, b: i64) -> i64 { if a == b { return 1 } return 0 }
called by 1: main
9func sg_frame2(a: *i64, b: *i64, na: *u8, nb: *u8, n: i64) -> *u8
called by 1: main calls 2: cf_encoded_bytescf_encode
22func main() -> i64