Struct timely::dataflow::operators::generic::OutputHandle

pub struct OutputHandle<'a, T: Timestamp, D: 'a, P: Push<Bundle<T, D>> + 'a> { /* fields omitted */ }

Handle to an operator’s output stream.

Implementations

impl<'a, T: Timestamp, D, P: Push<Bundle<T, D>>> OutputHandle<'a, T, D, P>

pub fn session<'b, C: CapabilityTrait<T>>(
    &'b mut self,
    cap: &'b C
) -> Session<'b, T, D, PushCounter<T, D, P>> where
    'a: 'b, 

Obtains a session that can send data at the timestamp associated with capability cap.

In order to send data at a future timestamp, obtain a capability for the new timestamp first, as show in the example.

Examples

use timely::dataflow::operators::ToStream;
use timely::dataflow::operators::generic::Operator;
use timely::dataflow::channels::pact::Pipeline;

timely::example(|scope| {
    (0..10).to_stream(scope)
           .unary(Pipeline, "example", |_cap, _info| |input, output| {
               input.for_each(|cap, data| {
                   let time = cap.time().clone() + 1;
                   output.session(&cap.delayed(&time))
                         .give_vec(&mut data.replace(Vec::new()));
               });
           });
});

Trait Implementations

impl<'a, T: Timestamp, D, P: Push<Bundle<T, D>>> Drop for OutputHandle<'a, T, D, P>

fn drop(&mut self)

Executes the destructor for this type.