Skip to content

Commit 9a19627

Browse files
committed
Update other projects
1 parent c712d0b commit 9a19627

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

interactive/src/plan/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ impl<V: ExchangeData+Hash+Datum> Render for Plan<V> {
158158
Plan::Distinct(distinct) => {
159159

160160
use differential_dataflow::operators::arrange::ArrangeBySelf;
161-
use differential_dataflow::trace::implementations::KeySpine;
161+
use differential_dataflow::trace::implementations::{KeyBuilder, KeySpine};
162162

163163
let input =
164164
if let Some(mut trace) = arrangements.get_unkeyed(&self) {
@@ -170,7 +170,7 @@ impl<V: ExchangeData+Hash+Datum> Render for Plan<V> {
170170
input_arrangement
171171
};
172172

173-
let output = input.reduce_abelian::<_,_,_,KeySpine<_,_,_>>("Distinct", move |_,_,t| t.push(((), 1)));
173+
let output = input.reduce_abelian::<_,_,_,KeyBuilder<_,_,_>,KeySpine<_,_,_>>("Distinct", move |_,_,t| t.push(((), 1)));
174174

175175
arrangements.set_unkeyed(&self, &output.trace);
176176
output.as_collection(|k,&()| k.clone())

0 commit comments

Comments
 (0)