Trait TDataStream 

pub trait TDataStream {
    // Required methods
    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: WatermarkStrategy + '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;
}

A DataStream represents a stream of elements of the same type. A DataStream can be transformed into another DataStream by applying a transformation

Required Methods

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: WatermarkStrategy + 'static,

fn connect<F>(self, data_streams: Vec<CoStream>, f: F) -> ConnectedStreams

where F: CoProcessFunction + 'static,

Re-balance: Round-robin, Hash, Broadcast

fn add_sink<O>(self, output_format: O)

where O: OutputFormat + 'static,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl TDataStream for DataStream