def getDuration()

in src/main/scala/com/aliyun/emr/example/spark/streaming/benchmark/metrics/BasicMetrics.scala [7:15]

• 9 lines of code
• 2 McCabe index (conditional complexity)

  def getDuration(value: String, separator: String = ",") : Option[Long] = {
    val values = value.split(separator)
    if (values.length != 2) {
      println("invalid result when parse start-time and finish time, invalid pattern should be start-time,end-time. content:" + value)
      return None
    }
    val duration = values(1).toLong - values(0).toLong
    Some(duration)
  }