Trait ResultsIn

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

Extension trait for streams.

Required Methods

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

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

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

Implementors

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>,