def main()

in src/main/g8/src/main/scala/$organization__packaged$/WordCount.scala [15:35]

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

  def main(cmdlineArgs: Array[String]): Unit = {
    val (sc, args) = ContextAndArgs(cmdlineArgs)

    val exampleData = "gs://dataflow-samples/shakespeare/kinglear.txt"
    val input = args.getOrElse("input", exampleData)
    val output = args("output")

    sc.textFile(input)
      .map(_.trim)
      .flatMap(_.split("[^a-zA-Z']+").filter(_.nonEmpty))
      .countByValue
      .map(t => t._1 + ": " + t._2)
      .saveAsTextFile(output)


    $if(DataflowFlexTemplate.truthy)$
    sc.run()
    $else$
    val result = sc.run().waitUntilDone()
    $endif$
  }