pub fn consolidate_up_to(
            &mut self,
            upper: Antichain<Timestamp>,
        ) -> Vec<(Timestamp, Row, Diff)> {
            differential_dataflow::consolidation::consolidate_updates(&mut self.buffer);
            let split_point = self
                .buffer
                .partition_point(|(t, _, _)| !upper.less_equal(t));
            self.buffer.drain(0..split_point).collect()
        }
/// Return all the updates with time less than `upper`,
/// in sorted and consolidated representation.
Return all the updates with time less than `upper`,
in sorted and consolidated representation.
Return all the updates with time less than ` upper ` in sorted and consolidated representation .
pub fn consolidate_up_to(
            &mut self,
            upper: Antichain<Timestamp>,
        ) -> Vec<(Timestamp, Row, Diff)> {
            differential_dataflow::consolidation::consolidate_updates(&mut self.buffer);
            let split_point = self
                .buffer
                .partition_point(|(t, _, _)| !upper.less_equal(t));
            self.buffer.drain(0..split_point).collect()
        }
pub fn consolidate_up_to ( & mut self , upper : Antichain < Timestamp > , ) -> Vec < ( Timestamp , Row , Diff ) > { differential_dataflow :: consolidation :: consolidate_updates ( & mut self . buffer ) ; let split_point = self . buffer . partition_point ( | ( t , _ , _ ) | ! upper . less_equal ( t ) ) ; self . buffer . drain ( 0 .. split_point ) . collect ( ) }
Return all the updates with time less than `upper`,
in sorted and consolidated representation.
Return all the updates with time less than ` upper ` in sorted and consolidated representation .
&mut self
upper
Antichain<Timestamp>