Skip to main content

merge_pair

differential_dataflow::columnar::trie_merger

Function merge_pair 

Source 
pub fn merge_pair<U: Update>(
    batch1: &mut Option<((usize, usize, usize), UpdatesTyped<U>)>,
    batch2: &mut Option<((usize, usize, usize), UpdatesTyped<U>)>,
) -> UpdatesTyped<U>
where
    U::Time: 'static,
Expand description

Merge two batches, one completely and the other through the corresponding prefix, returning the merged output and leaving each input’s unconsumed suffix in batch1 / batch2 (via an updated (key, val, time) cursor) or None if it was fully consumed.

Driven by the columnar Chunk impl’s merge, which materializes the surviving suffix with suffix_chunk and pushes it back to its deque.