differential_dataflow::operators::iterate

Trait ResultsIn

Source
pub trait ResultsIn<G: Scope, C> {
    // Required method
    fn results_in(&self, step: <G::Timestamp as Timestamp>::Summary) -> Self;
}
Expand description

Extension trait for streams.

Required Methods§

Source

fn results_in(&self, step: <G::Timestamp as Timestamp>::Summary) -> Self

Advances a timestamp in the stream according to the timestamp actions on the path.

The path may advance the timestamp sufficiently that it is no longer valid, for example if incrementing fields would result in integer overflow. In this case, the record is dropped.

§Examples
use timely::dataflow::Scope;
use timely::dataflow::operators::{ToStream, Concat, Inspect, BranchWhen};

use differential_dataflow::input::Input;
use differential_dataflow::operators::ResultsIn;

timely::example(|scope| {
    let summary1 = 5;

    let data = scope.new_collection_from(1 .. 10).1;
    /// Applies `results_in` on every timestamp in the collection.
    data.results_in(summary1);
});

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types§

Source§

impl<G: Scope, D: Data, R: Data> ResultsIn<G, Vec<(D, <G as ScopeParent>::Timestamp, R)>> for Stream<G, (D, G::Timestamp, R)>

Source§

fn results_in(&self, step: <G::Timestamp as Timestamp>::Summary) -> Self

Implementors§

Source§

impl<G, D, R, C> ResultsIn<G, C> for Collection<G, D, R, C>
where G: Scope, C: Clone, StreamCore<G, C>: ResultsIn<G, C>,