risingwave_frontend::optimizer::plan_node

Trait TryToStreamPb

Source 
pub trait TryToStreamPb {
    // Provided method
    fn try_to_stream_prost_body(
        &self,
        _state: &mut BuildFragmentGraphState,
    ) -> Result<NodeBody, SchedulerError> { ... }
}

Provided Methods§

Source

fn try_to_stream_prost_body( &self, _state: &mut BuildFragmentGraphState, ) -> Result<NodeBody, SchedulerError>

Implementors§