risingwave_stream::executor::wrapper::trace

Function trace

source 
pub fn trace(
    enable_executor_row_count: bool,
    info: Arc<ExecutorInfo>,
    actor_ctx: ActorContextRef,
    input: impl MessageStream,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>
Expand description

Streams wrapped by trace will be traced with tracing spans and reported to opentelemetry.