table_name method in OTLP TraceParser trait

src/frontend/src/instance/otlp.rs

@@ -71,12 +71,15 @@ impl OpenTelemetryProtocolHandler for Instance {
             .check_permission(ctx.current_user(), PermissionReq::Otlp)
             .context(AuthSnafu)?;
 
-        let spans = match self.plugins.get::<TraceParserRef>() {
-            Some(parser) => parser.parse(request),
-            None => otlp::trace::parse(request),
+        let (table_name, spans) = match self.plugins.get::<TraceParserRef>() {
+            Some(parser) => (parser.table_name(), parser.parse(request)),
+            None => (
+                otlp::trace::TRACE_TABLE_NAME.to_string(),
+                otlp::trace::parse(request),
+            ),
         };
 
-        let (requests, rows) = otlp::trace::to_grpc_insert_requests(spans)?;
+        let (requests, rows) = otlp::trace::to_grpc_insert_requests(table_name, spans)?;
 
         let _ = self
             .handle_row_inserts(requests, ctx)

src/servers/src/otlp/plugin.rs

@@ -22,6 +22,7 @@ use super::trace::TraceSpans;
 ///   - uplift some fields from Attributes (Map type) to column
 pub trait TraceParser: Send + Sync {
     fn parse(&self, request: ExportTraceServiceRequest) -> TraceSpans;
+    fn table_name(&self) -> String;
 }
 
 pub type TraceParserRef = Arc<dyn TraceParser>;

src/servers/src/otlp/trace.rs

@@ -33,7 +33,7 @@ use crate::error::Result;
 use crate::row_writer::{self, MultiTableData, TableData};
 
 const APPROXIMATE_COLUMN_COUNT: usize = 16;
-const TRACE_TABLE_NAME: &str = "traces_preview_v01";
+pub const TRACE_TABLE_NAME: &str = "traces_preview_v01";
 
 #[derive(Debug, Clone)]
 #[allow(dead_code)]
@@ -71,10 +71,13 @@ pub type TraceSpans = Vec<TraceSpan>;
 /// for data structure of OTLP metrics.
 ///
 /// Returns `InsertRequests` and total number of rows to ingest
-pub fn to_grpc_insert_requests(spans: TraceSpans) -> Result<(RowInsertRequests, usize)> {
+pub fn to_grpc_insert_requests(
+    table_name: String,
+    spans: TraceSpans,
+) -> Result<(RowInsertRequests, usize)> {
     let mut multi_table_writer = MultiTableData::default();
     let one_table_writer = multi_table_writer.get_or_default_table_data(
-        TRACE_TABLE_NAME,
+        table_name,
         APPROXIMATE_COLUMN_COUNT,
         APPROXIMATE_COLUMN_COUNT,
     );