Struct rlink::core::env::StreamExecutionEnvironment [−][src]
pub struct StreamExecutionEnvironment { /* fields omitted */ }
Implementations
pub fn register_source<I>(&mut self, input_format: I) -> DataStream where
I: InputFormat + 'static,
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for StreamExecutionEnvironment
impl !Send for StreamExecutionEnvironment
impl !Sync for StreamExecutionEnvironment
impl Unpin for StreamExecutionEnvironment
impl !UnwindSafe for StreamExecutionEnvironment
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
type Output = T
type Output = T
Should always be Self