Struct PerfettoTraceTableFunction 

pub struct PerfettoTraceTableFunction { /* private fields */ }

PerfettoTraceTableFunction generates Perfetto trace chunks from process telemetry data.

SQL Interface:

SELECT chunk_id, chunk_data
FROM perfetto_trace_chunks(
    'process_id',                              -- Process UUID (required)
    'span_types',                              -- 'thread', 'async', or 'both' (required)
    TIMESTAMP '2024-01-01T00:00:00Z',          -- Start time as UTC timestamp (required)
    TIMESTAMP '2024-01-01T01:00:00Z'           -- End time as UTC timestamp (required)
) ORDER BY chunk_id

Returns a table with schema:

• chunk_id: Int32 - Sequential chunk identifier
• chunk_data: Binary - Binary protobuf TracePacket data

Implementations

impl PerfettoTraceTableFunction

pub fn new( lakehouse: Arc<LakehouseContext>, view_factory: Arc<ViewFactory>, part_provider: Arc<dyn QueryPartitionProvider>, ) -> PerfettoTraceTableFunction

pub fn output_schema() -> Arc<Schema>

Create the output schema for the table function

Trait Implementations

impl Debug for PerfettoTraceTableFunction

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl TableFunctionImpl for PerfettoTraceTableFunction

fn call( &self, exprs: &[Expr], ) -> Result<Arc<dyn TableProvider>, DataFusionError>

Create a table provider