Trait mz_storage::ComputeReplay
source · [−]pub trait ComputeReplay {
fn replay<G: Scope<Timestamp = Timestamp>>(
&mut self,
scope: &mut G,
name: &str,
request: SourceInstanceRequest
) -> (Collection<G, Row, Diff>, Collection<G, DataflowError, Diff>, Rc<dyn Any>);
}Expand description
A type that can replay specific sources
Required methods
fn replay<G: Scope<Timestamp = Timestamp>>(
&mut self,
scope: &mut G,
name: &str,
request: SourceInstanceRequest
) -> (Collection<G, Row, Diff>, Collection<G, DataflowError, Diff>, Rc<dyn Any>)
fn replay<G: Scope<Timestamp = Timestamp>>(
&mut self,
scope: &mut G,
name: &str,
request: SourceInstanceRequest
) -> (Collection<G, Row, Diff>, Collection<G, DataflowError, Diff>, Rc<dyn Any>)
Replays the source bound to id.
None is returned if the source does not exist, either because
it was not there to begin, or has already been replayed. Either
case is likely an error.