private def parseLogVersion()

in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala [148:174]

• 26 lines of code
• 7 McCabe index (conditional complexity)

        private def parseLogVersion(text: String, maxSupportedVersion: Int): Int = {
          if (text.length > 0 && text(0) == 'v') {
            val version =
              try {
                text.substring(1, text.length).toInt
              } catch {
                case _: NumberFormatException =>
                  throw new IllegalStateException(
                    s"Log file was malformed: failed to read correct log " +
                      s"version from $text.")
              }
            if (version > 0) {
              if (version > maxSupportedVersion) {
                throw new IllegalStateException(
                  s"UnsupportedLogVersion: maximum supported log version " +
                    s"is v${maxSupportedVersion}, but encountered v$version. The log file was produced " +
                    s"by a newer version of Spark and cannot be read by this version. Please upgrade.")
              } else {
                return version
              }
            }
          }
          // reaching here means we failed to read the correct log version
          throw new IllegalStateException(
            s"Log file was malformed: failed to read correct log " +
              s"version from $text.")
        }