in src/main/scala/com/spotify/bdrc/pipeline/CountDistinctItems.scala [63:67]
def scioApprox(input: SCollection[Rating]): SCollection[Long] = { input .map(_.item) .countApproxDistinct() }