risingwave_stream::executor::wrapper::stream_node_metrics

Function stream_node_metrics

Source 
pub fn stream_node_metrics(
    info: Arc<ExecutorInfo>,
    enable_explain_analyze_stats: bool,
    input: impl MessageStream,
    actor_ctx: ActorContextRef,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>