Skip to content

Commit 2f54814

Browse files
committed
Respond to comments
1 parent a22042f commit 2f54814

File tree

2 files changed

+4
-2
lines changed
  • differential-dataflow/src

2 files changed

+4
-2
lines changed

differential-dataflow/src/operators/join.rs

+1-2
Original file line numberDiff line numberDiff line change
@@ -679,8 +679,7 @@ where
679679

680680
// populate `temp` with the results in the best way we know how.
681681
thinker.think(|v1,v2,t,r1,r2| {
682-
let key = batch_key;
683-
logic(key, v1, v2, &t, r1, r2, &mut session);
682+
logic(batch_key, v1, v2, &t, r1, r2, &mut session);
684683
});
685684

686685
// TODO: Effort isn't perfectly tracked as we might still have some data in the

differential-dataflow/src/trace/implementations/mod.rs

+3
Original file line numberDiff line numberDiff line change
@@ -568,6 +568,9 @@ pub mod containers {
568568
fn index(&self, index: usize) -> Self::ReadItem<'_> {
569569
&self[index]
570570
}
571+
fn get(&self, index: usize) -> Option<Self::ReadItem<'_>> {
572+
<[T]>::get(&self, index)
573+
}
571574
fn len(&self) -> usize {
572575
self[..].len()
573576
}

0 commit comments

Comments
 (0)