def scio()

in src/main/scala/com/spotify/bdrc/pipeline/WordCount.scala [39:43]


  def scio(input: SCollection[String]): SCollection[(String, Long)] = {
    input
      .flatMap(_.split("[^a-zA-Z']+").filter(_.nonEmpty))
      .countByValue
  }