feat: support traces_input_dist

metrico · Oct 14, 2024 · 174fb7c · 174fb7c
1 parent b17cde3
commit 174fb7c
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/exporter/qrynexporter/schema.go b/exporter/qrynexporter/schema.go
@@ -21,7 +21,11 @@ import (
 
 var (
 	tracesInputSQL = func(clustered bool) string {
-		return `INSERT INTO traces_input (
+		dist := ""
+		if clustered {
+			dist = "_dist"
+		}
+		return fmt.Sprintf(`INSERT INTO traces_input%s (
   trace_id, 
   span_id, 
   parent_id, 
@@ -31,7 +35,7 @@ var (
   service_name,
   payload_type, 
   payload, 
-  tags)`
+  tags)`, dist)
 	}
 	samplesSQL = func(clustered bool) string {
 		dist := ""