def transformCommitterInfo()

in gitcommits/src/main/scala/com/gerritforge/analytics/gitcommits/engine/GerritAnalyticsTransformations.scala [126:150]

• 25 lines of code
• 1 McCabe index (conditional complexity)

    def transformCommitterInfo()(implicit spark: SparkSession): DataFrame = {
      import org.apache.spark.sql.functions.from_json
      import spark.sqlContext.implicits._
      df.withColumn("json", from_json($"json", schema))
        .selectExpr(
          "project",
          "json.name as author",
          "json.email as email",
          "json.year as year",
          "json.month as month",
          "json.day as day",
          "json.hour as hour",
          "json.num_files as num_files",
          "json.num_distinct_files as num_distinct_files",
          "json.added_lines as added_lines",
          "json.deleted_lines as deleted_lines",
          "json.num_commits as num_commits",
          "json.last_commit_date as last_commit_date",
          "json.is_merge as is_merge",
          "json.commits as commits",
          "json.branches as branches",
          "json.is_bot_like",
          "json.hash_tags as hash_tags"
        )
    }