Trait mz_dataflow::ComputeReplay

pub trait ComputeReplay {
    fn replay<G>(
        &mut self, 
        scope: &mut G, 
        name: &str, 
        request: SourceInstanceRequest<u64>
    ) -> (Collection<G, Row, i64>, Collection<G, DataflowError, i64>, Rc<dyn Any + 'static>)
    where
        G: Scope<Timestamp = u64>;
}

A type that can replay specific sources

Required methods

fn replay<G>(
    &mut self,
    scope: &mut G,
    name: &str,
    request: SourceInstanceRequest<u64>
) -> (Collection<G, Row, i64>, Collection<G, DataflowError, i64>, Rc<dyn Any + 'static>) where
    G: Scope<Timestamp = u64>, 

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.

Implementations on Foreign Types

impl<CR> ComputeReplay for Rc<RefCell<CR>> where
    CR: ComputeReplay, 

fn replay<G>(
    &mut self,
    scope: &mut G,
    name: &str,
    request: SourceInstanceRequest<u64>
) -> (Collection<G, Row, i64>, Collection<G, DataflowError, i64>, Rc<dyn Any + 'static>) where
    G: Scope<Timestamp = u64>, 

Implementors

impl ComputeReplay for DummyBoundary

impl ComputeReplay for EventLinkBoundary

impl ComputeReplay for TcpEventLinkClientHandle