Skip to main content

fold

Function fold 

Source
pub fn fold(batches: &[RecordBatch]) -> Result<BTreeMap<String, RefState>>
Expand description

Replay pushes into the current namespace. Last writer wins by push_seq; a null target and no symref_target deletes the ref.

Ordering is by push_seq and never by position in the vector, so a caller that hands the batches over out of order still gets the right answer.