@@ -36,21 +36,21 @@ use std::ops::Mul;
3636use std:: time:: Instant ;
3737
3838use timely:: container:: { CapacityContainerBuilder , ContainerBuilder } ;
39+ use timely:: dataflow:: { Scope , ScopeParent , StreamCore } ;
3940use timely:: dataflow:: channels:: pact:: { Pipeline , Exchange } ;
4041use timely:: dataflow:: channels:: pushers:: buffer:: Session ;
4142use timely:: dataflow:: channels:: pushers:: { Counter as PushCounter , Tee } ;
4243use timely:: dataflow:: operators:: Operator ;
43- use timely:: dataflow:: { Scope , ScopeParent , StreamCore } ;
4444use timely:: progress:: Antichain ;
4545use timely:: progress:: frontier:: AntichainRef ;
4646
47- use differential_dataflow:: consolidation :: { consolidate , consolidate_updates } ;
47+ use differential_dataflow:: { ExchangeData , Collection , AsCollection , Hashable } ;
4848use differential_dataflow:: difference:: { Monoid , Semigroup } ;
4949use differential_dataflow:: lattice:: Lattice ;
5050use differential_dataflow:: operators:: arrange:: Arranged ;
51- use differential_dataflow:: trace:: cursor:: IntoOwned ;
5251use differential_dataflow:: trace:: { Cursor , TraceReader } ;
53- use differential_dataflow:: { ExchangeData , Collection , AsCollection , Hashable } ;
52+ use differential_dataflow:: consolidation:: { consolidate, consolidate_updates} ;
53+ use differential_dataflow:: trace:: cursor:: IntoOwned ;
5454
5555/// A binary equijoin that responds to updates on only its first input.
5656///
0 commit comments