Struct SpillingHashJoin 

pub struct SpillingHashJoin<'a> { /* private fields */ }

ASP-Join with spill-to-disk support for large intermediate hash tables.

When the hash map built from a source node’s 2-hop neighbourhood exceeds SPILL_THRESHOLD entries, the operator partitions intermediate data into temp files and processes them one partition at a time.

Implementations

impl<'a> SpillingHashJoin<'a>

pub fn new(csr: &'a CsrForward) -> Self

Create with default thresholds.

pub fn with_thresholds( csr: &'a CsrForward, spill_threshold: usize, num_partitions: usize, ) -> Self

Create with explicit thresholds (useful for testing spill behaviour).

pub fn two_hop(&self, src_slot: u64) -> Result<Vec<u64>>

Compute 2-hop friends-of-friends for src_slot.

Returns a deduplicated, sorted set of fof slots, identical in semantics to [AspJoin::two_hop].