in src/main/scala/com/spotify/bdrc/pipeline/CountUsers.scala [48:52]
def scio(input: SCollection[Rating]): SCollection[Long] = { input .filter(_.user == "Smith") .count }