Skip to content

Commit

Permalink
forgot some files
Browse files Browse the repository at this point in the history
  • Loading branch information
cjc7373 committed Nov 10, 2023
1 parent ee30359 commit 6b1e647
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 3 deletions.
2 changes: 1 addition & 1 deletion aw-query/src/functions.rs
Original file line number Diff line number Diff line change
Expand Up @@ -506,7 +506,7 @@ mod qfunctions {
let events: Vec<Event> = (&args[0]).try_into()?;
let filter_events: Vec<Event> = (&args[1]).try_into()?;

let mut filtered_events = aw_transform::filter_period_intersect(&events, &filter_events);
let mut filtered_events = aw_transform::filter_period_intersect(events, filter_events);
let mut filtered_tagged_events = Vec::new();
for event in filtered_events.drain(..) {
filtered_tagged_events.push(DataType::Event(event));
Expand Down
2 changes: 1 addition & 1 deletion aw-transform/benches/bench.rs
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ fn bench_filter_period_intersect(c: &mut Criterion) {
c.bench_function("1000 events", |b| {
b.iter(|| {
let events1 = create_events(1000);
filter_period_intersect(&events1, &events2);
filter_period_intersect(events1, events2.clone());
})
});
}
Expand Down
1 change: 0 additions & 1 deletion aw-transform/src/filter_period.rs
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,6 @@ pub fn filter_period_intersect(events: Vec<Event>, filter_events: Vec<Event>) ->
let mut cur_filter_event = filter_events_iter.next().unwrap();

loop {
// TODO: what about duration = 0?
let event_endtime = cur_event.calculate_endtime();
let filter_endtime = cur_filter_event.calculate_endtime();
if cur_event.duration == Duration::seconds(0) || event_endtime <= cur_filter_event.timestamp {
Expand Down

0 comments on commit 6b1e647

Please sign in to comment.