arcon/dataflow/stream/keyed/
mod.rs

1use crate::data::ArconType;
2use crate::dataflow::stream::Stream;
3
4/// Represents a stream that has been keyed
5pub struct KeyedStream<T: ArconType> {
6    pub(crate) stream: Stream<T>,
7}
8
9impl<T: ArconType> KeyedStream<T> {
10    pub(super) fn from(stream: Stream<T>) -> Self {
11        Self { stream }
12    }
13}