arcon 0.2.1

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

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

/// A Stream that supports Arrow analytics
pub struct ArrowStream<T: ArconType + ToArrow> {
    pub(crate) stream: Stream<T>,
}

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