feat(exporter): unified Arrow exporter with GUC + end-to-end TAP test

include/config/guc.h

@@ -33,6 +33,7 @@ extern int psch_min_duration_us;
 extern int psch_normalize_cache_max;
 extern double psch_sample_rate;
 extern bool psch_otel_arrow_passthrough;
+extern bool psch_use_unified_arrow_exporter;
 extern int psch_otel_max_block_bytes;
 extern char* psch_extra_attributes;
 extern char* psch_debug_arrow_dump_dir;

src/config/guc.c

@@ -35,6 +35,7 @@ int psch_min_duration_us = 0;
 int psch_normalize_cache_max = 32768;
 double psch_sample_rate = 1.0;
 bool psch_otel_arrow_passthrough = false;
+bool psch_use_unified_arrow_exporter = false;
 int psch_otel_max_block_bytes = 3 * 1024 * 1024;  // 3 MiB (max: 16 MiB)
 char* psch_extra_attributes = NULL;
 char* psch_debug_arrow_dump_dir = NULL;
@@ -356,6 +357,23 @@ void PschInitGuc(void) {
       0,
       NULL, NULL, NULL);
 
+  DefineCustomBoolVariable(
+      "pg_stat_ch.use_unified_arrow_exporter",
+      "Use the StatsExporter-implementing Arrow exporter instead of arrow_batch.cc.",
+      "When enabled together with use_otel and otel_arrow_passthrough, the bgworker "
+      "builds Arrow IPC via the typed StatsExporter column interface, writing the "
+      "events_raw schema (typed integer ids, no sprintf decimal-string encoding). "
+      "When off, the legacy arrow_batch.cc path runs and produces the query_logs_arrow "
+      "wire shape. Default off; flip on to opt a producer into the new exporter. "
+      "PGC_POSTMASTER: the bgworker picks the exporter implementation at init time, "
+      "so a runtime change would mismatch the per-cycle dispatcher (Arrow batches "
+      "would silently drop, since OTelArrowExporter does not implement SendArrowBatch).",
+      &psch_use_unified_arrow_exporter,
+      false,
+      PGC_POSTMASTER,
+      0,
+      NULL, NULL, NULL);
+
   DefineCustomIntVariable(
       "pg_stat_ch.otel_max_block_bytes",
       "Maximum Arrow batch size in bytes per OTLP request.",

src/export/exporter_interface.h

@@ -90,10 +90,20 @@ class StatsExporter {
   virtual int NumConsecutiveFailures() const = 0;
   virtual void ResetFailures() = 0;
   virtual int NumExported() const = 0;
-  virtual bool SendArrowBatch(const uint8_t* ipc_data, size_t ipc_len, int num_rows) {
+  // block_format is the discriminator emitted as the
+  // pg_stat_ch.block_format resource + log-record attribute on the OTLP
+  // request. The central OTel collector's routingconnector matches on
+  // it to fan to the right downstream receiver (e.g. legacy
+  // query_logs_arrow vs new events_raw). Callers pass an explicit value
+  // because Google Style forbids default arguments on virtual methods
+  // (the default is dispatched on the static type, not the dynamic one,
+  // which is a footgun for overriders).
+  virtual bool SendArrowBatch(const uint8_t* ipc_data, size_t ipc_len, int num_rows,
+                              string_view block_format) {
     (void)ipc_data;
     (void)ipc_len;
     (void)num_rows;
+    (void)block_format;
     return false;
   }