From 174fb7c901f183eac16ef0130d12d9908136cc65 Mon Sep 17 00:00:00 2001
From: Cluas <Cluas@live.cn>
Date: Mon, 14 Oct 2024 16:08:31 +0800
Subject: [PATCH] feat: support traces_input_dist

---
 exporter/qrynexporter/schema.go | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/exporter/qrynexporter/schema.go b/exporter/qrynexporter/schema.go
index fed1546..b158a7d 100644
--- 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 := ""