servers::otlp::trace::v1

Function v1_to_grpc_insert_requests

Source 
pub fn v1_to_grpc_insert_requests(
    request: ExportTraceServiceRequest,
    _pipeline: PipelineWay,
    _pipeline_params: GreptimePipelineParams,
    table_name: String,
    _query_ctx: &QueryContextRef,
    _pipeline_handler: PipelineHandlerRef,
) -> Result<(RowInsertRequests, usize)>
Expand description

Convert SpanTraces to GreptimeDB row insert requests. Returns InsertRequests and total number of rows to ingest

Compared with v0, this v1 implementation:

  1. flattens all attribute data into columns.
  2. treat span_id and parent_trace_id as fields.
  3. removed service_name column because it’s already in resource_attributes.service_name

For other compound data structures like span_links and span_events here we are still using json data structure.