Crate datafusion_common_runtime

Source

Re-exports§

pub use common::SpawnedTask;

Modules§

common

Structs§

JoinSet
A wrapper around Tokio’s JoinSet that forwards all API calls while optionally instrumenting spawned tasks and blocking closures with custom tracing behavior. If no tracer is injected via trace_utils::set_tracer, tasks and closures are executed without any instrumentation.

Traits§

JoinSetTracer
A trait for injecting instrumentation into either asynchronous futures or blocking closures at runtime.

Functions§

set_join_set_tracer
Set the custom tracer for both futures and blocking closures.