public PulsarConnectorMetricsTracker()

in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorMetricsTracker.java [137:169]
32 lines of code
3 McCabe index (conditional complexity)

    public PulsarConnectorMetricsTracker(StatsProvider statsProvider) {
        this.statsLogger = statsProvider instanceof NullStatsProvider
                ? null : statsProvider.getStatsLogger(SCOPE);

        if (this.statsLogger != null) {
            statsLoggerEntryQueueDequeueWaitTime = statsLogger.getOpStatsLogger(ENTRY_QUEUE_DEQUEUE_WAIT_TIME);
            statsLoggerBytesRead = statsLogger.getCounter(BYTES_READ);
            statsLoggerEntryDeserializeTime = statsLogger.getOpStatsLogger(ENTRY_DESERIALIZE_TIME);
            statsLoggerMessageQueueEnqueueWaitTime = statsLogger.getOpStatsLogger(MESSAGE_QUEUE_ENQUEUE_WAIT_TIME);
            statsLoggerNumMessagesDeserialized = statsLogger.getCounter(NUM_MESSAGES_DERSERIALIZED);
            statsLoggerNumMessagesDeserializedPerEntry = statsLogger
                .getOpStatsLogger(NUM_MESSAGES_DERSERIALIZED_PER_ENTRY);
            statsLoggerReadAttempts = statsLogger.getOpStatsLogger(READ_ATTEMPTS);
            statsLoggerReadLatencyPerBatch = statsLogger.getOpStatsLogger(READ_LATENCY_PER_BATCH);
            statsLoggerNumEntriesPerBatch = statsLogger.getOpStatsLogger(NUM_ENTRIES_PER_BATCH);
            statsLoggerRecordDeserializeTime = statsLogger.getOpStatsLogger(RECORD_DESERIALIZE_TIME);
            statsLoggerNumRecordDeserialized = statsLogger.getCounter(NUM_RECORD_DESERIALIZED);
            statsLoggerTotalExecutionTime = statsLogger.getOpStatsLogger(TOTAL_EXECUTION_TIME);
        } else {
            statsLoggerEntryQueueDequeueWaitTime = null;
            statsLoggerBytesRead = null;
            statsLoggerEntryDeserializeTime = null;
            statsLoggerMessageQueueEnqueueWaitTime = null;
            statsLoggerNumMessagesDeserialized = null;
            statsLoggerNumMessagesDeserializedPerEntry = null;
            statsLoggerReadAttempts = null;
            statsLoggerReadLatencyPerBatch = null;
            statsLoggerNumEntriesPerBatch = null;
            statsLoggerRecordDeserializeTime = null;
            statsLoggerNumRecordDeserialized = null;
            statsLoggerTotalExecutionTime = null;
        }
    }