Module thread_spans_view 

Jit view of the call tree built from the thread events of a single stream

Structs

ThreadSpansView

A view of thread spans.

ThreadSpansViewMaker

A ViewMaker for creating ThreadSpansView instances.

Functions

ensure_begin_non_decreasing

Verifies that batch’s begin column is non-decreasing, naming stream_id and the offending row/values in both the returned error and (unlike a plain anyhow::ensure!) an error! log line emitted immediately before it: nothing on ensure_begin_non_decreasing‘s callers’ error propagation path (MaterializedView::scan -> DataFusion planning -> the flight SQL service) logs a planning-time error at error level, so the check logs itself instead of relying on that propagation.

update_partition

Rebuilds the partition if it’s missing or out of date.