arcon 0.2.1

A runtime for writing streaming applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

use crate::data::ArconType;
use crate::dataflow::stream::Stream;

/// Represents a stream that has been keyed
pub struct KeyedStream<T: ArconType> {
    pub(crate) stream: Stream<T>,
}

impl<T: ArconType> KeyedStream<T> {
    pub(super) fn from(stream: Stream<T>) -> Self {
        Self { stream }
    }
}