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§
Sourcefn results_in(&self, step: <G::Timestamp as Timestamp>::Summary) -> Self
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.