Apache Spark оцените насколько всё плохо)

package movie
 
import org.apache.spark.{SparkConf, SparkContext}
 
import scala.util.matching.Regex
 
object Movie {
 
  def main(args: Array[String]): Unit = {
 
    def genres(genrs: String): Array[String] = {
      val arrs = if (genrs.contains("|")) {
        val arr: Array[String] = genrs.split('|')
        arr(arr.length - 1) = trim(arr(arr.length - 1))
        arr
      } else if (!genrs.contains("|") && !genrs.trim.equals("(no genre listed)") && !genrs.trim.equals("(no genre listed)"")) {
        Array(trim(genrs))
      }
      else new Array[String](0)
      arrs
    }
 
    def trim(str: String): String = if (str.contains(""")) {
      str.replace(""", "").trim()
    }
    else {
      str.trim
    }
 
    val conf = new SparkConf().setAppName("movie")
 
    val sc = new SparkContext(conf)
 
    val lines = sc.textFile("/user/spark/movies.txt")
 
    val pattern: Regex = """\(\d{4}\)""".r
 
    val ddr1 = lines.map(x => (pattern.findFirstMatchIn(x).get.toString, x.split(",")))
 
    val ddr2 = ddr1.flatMapValues(x => genres(x(x.length - 1)))
 
    val ddr3 = ddr2.map(x => (x._1 + x._2, 1))
 
    val result = ddr3.reduceByKey((x, y) => x + y)
 
    result.saveAsTextFile("/user/result/streams")
 
  }
 
}