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 }