Struct rlink::core::data_stream::ConnectedStreams [−][src]
pub struct ConnectedStreams { /* fields omitted */ }
Trait Implementations
Unlike flink, the key_by
that receives only one KeySelector,
that is, CoProcessFunction
method output must have the same schema or with special flag. Read more
Auto Trait Implementations
impl !RefUnwindSafe for ConnectedStreams
impl !Send for ConnectedStreams
impl !Sync for ConnectedStreams
impl Unpin for ConnectedStreams
impl !UnwindSafe for ConnectedStreams
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