Add SqlExecutionEvent fields to telemetry

- Add statement_type field from operationType
- Add is_compressed field from compression tracking
- Export both fields in sql_operation for statement metrics
- Fields populated from CloudFetch chunk events

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>

Author: samikshya-db

lib/telemetry/DatabricksTelemetryExporter.ts

@@ -55,6 +55,8 @@ interface DatabricksTelemetryLog {
       driver_connection_params?: any;
       operation_latency_ms?: number;
       sql_operation?: {
+        statement_type?: string;
+        is_compressed?: boolean;
         execution_result?: string;
         chunk_details?: {
           total_chunks_present?: number;
@@ -300,17 +302,18 @@ export default class DatabricksTelemetryExporter {
     } else if (metric.metricType === 'statement') {
       log.entry.sql_driver_log.operation_latency_ms = metric.latencyMs;
 
-      if (metric.resultFormat || metric.chunkCount) {
-        log.entry.sql_driver_log.sql_operation = {
-          execution_result: metric.resultFormat,
-        };
+      // Always create sql_operation for statement events
+      log.entry.sql_driver_log.sql_operation = {
+        statement_type: metric.operationType,
+        is_compressed: metric.compressed,
+        execution_result: metric.resultFormat,
+      };
 
-        if (metric.chunkCount && metric.chunkCount > 0) {
-          log.entry.sql_driver_log.sql_operation.chunk_details = {
-            total_chunks_present: metric.chunkCount,
-            total_chunks_iterated: metric.chunkCount,
-          };
-        }
+      if (metric.chunkCount && metric.chunkCount > 0) {
+        log.entry.sql_driver_log.sql_operation.chunk_details = {
+          total_chunks_present: metric.chunkCount,
+          total_chunks_iterated: metric.chunkCount,
+        };
       }
     } else if (metric.metricType === 'error') {
       log.entry.sql_driver_log.error_info = {

lib/telemetry/MetricsAggregator.ts

@@ -252,11 +252,13 @@ export default class MetricsAggregator {
         sessionId: details.sessionId,
         statementId: details.statementId,
         workspaceId: details.workspaceId,
+        operationType: details.operationType,
         latencyMs: details.executionLatencyMs,
         resultFormat: details.resultFormat,
         chunkCount: details.chunkCount,
         bytesDownloaded: details.bytesDownloaded,
         pollCount: details.pollCount,
+        compressed: details.compressionEnabled,
       };
 
       this.addPendingMetric(metric);

lib/telemetry/types.ts

@@ -157,6 +157,9 @@ export interface TelemetryMetric {
   /** Execution latency in milliseconds */
   latencyMs?: number;
 
+  /** Type of operation (SELECT, INSERT, etc.) */
+  operationType?: string;
+
   /** Result format (inline, cloudfetch, arrow) */
   resultFormat?: string;
 
@@ -169,6 +172,9 @@ export interface TelemetryMetric {
   /** Number of poll operations */
   pollCount?: number;
 
+  /** Whether compression was used */
+  compressed?: boolean;
+
   /** Error name/type */
   errorName?: string;