Class TelemetryClientFactory


  • public class TelemetryClientFactory
    extends Object
    • Method Detail

      • closeTelemetryClient

        public void closeTelemetryClient​(IDatabricksConnectionContext connectionContext)
        Closes telemetry client for a connection. Thread-safe: computeIfPresent ensures atomic locking, preventing race conditions between connection removal and addition.

        The connection UUID is removed from the open set FIRST to prevent getTelemetryClient() from re-creating a TelemetryClient during or after the close sequence. Pending TelemetryCollector events are exported BEFORE the TelemetryClient is closed (inside try-finally), so they are flushed through the existing client. See GitHub issue #1325.

      • getTelemetryExecutorService

        public ExecutorService getTelemetryExecutorService()
      • reset

        public void reset()