Skip to content

Commit

Permalink
Generalize bounds on dynamic timestamp actions (TimelyDataflow#379)
Browse files Browse the repository at this point in the history
  • Loading branch information
frankmcsherry authored Feb 16, 2023
1 parent 24df201 commit cc88469
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions src/dynamic/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@

pub mod pointstamp;

use timely::dataflow::{Scope, scopes::Child};
use timely::dataflow::Scope;
use timely::order::Product;
use timely::progress::Timestamp;
use timely::dataflow::operators::generic::builder_rc::OperatorBuilder;
Expand All @@ -26,12 +26,13 @@ use collection::AsCollection;
use dynamic::pointstamp::PointStamp;
use dynamic::pointstamp::PointStampSummary;

impl<G, D, R, T> Collection<Child<'_, G, Product<G::Timestamp, PointStamp<T>>>, D, R>
impl<G, D, R, T, TOuter> Collection<G, D, R>
where
G: Scope,
G: Scope<Timestamp = Product<TOuter, PointStamp<T>>>,
D: Data,
R: Semigroup,
T: Timestamp+Default,
TOuter: Timestamp,
{
/// Enters a dynamically created scope which has `level` timestamp coordinates.
pub fn enter_dynamic(&self, _level: usize) -> Self {
Expand Down

0 comments on commit cc88469

Please sign in to comment.