Trait rlink::api::data_stream::TDataStream[−][src]

pub trait TDataStream {
    fn flat_map<F>(self, flat_mapper: F) -> DataStream
    where
        F: FlatMapFunction + 'static;

    fn filter<F>(self, filter: F) -> DataStream
    where
        F: FilterFunction + 'static;

    fn key_by<F>(self, key_selector: F) -> KeyedStream
    where
        F: KeySelectorFunction + 'static;

    fn assign_timestamps_and_watermarks<W>(
        self, 
        timestamp_and_watermark_assigner: W
    ) -> DataStream
    where
        W: WatermarkAssigner + 'static;

    fn connect<F>(self, data_streams: Vec<CoStream>, f: F) -> ConnectedStreams
    where
        F: CoProcessFunction + 'static;

    fn add_sink<O>(self, output_format: O)
    where
        O: OutputFormat + 'static;
}

Required methods

fn flat_map<F>(self, flat_mapper: F) -> DataStream where
    F: FlatMapFunction + 'static, [src]

fn filter<F>(self, filter: F) -> DataStream where
    F: FilterFunction + 'static, [src]

fn key_by<F>(self, key_selector: F) -> KeyedStream where
    F: KeySelectorFunction + 'static, [src]

fn assign_timestamps_and_watermarks<W>(
    self,
    timestamp_and_watermark_assigner: W
) -> DataStream where
    W: WatermarkAssigner + 'static, [src]

fn connect<F>(self, data_streams: Vec<CoStream>, f: F) -> ConnectedStreams where
    F: CoProcessFunction + 'static, [src]

Re-balance: Round-robin, Hash, Broadcast

fn add_sink<O>(self, output_format: O) where
    O: OutputFormat + 'static, [src]

Loading content...

Implementors

impl TDataStream for DataStream[src]

Loading content...