nevillelyh on master
Remove uneeded LowPriority impl… (compare)
Combine.perKeyoptimization works as expected
static class BoundedHeap<T, ComparatorT extends Comparator<T> & Serializable>in
SCollection. see this comparison f with spark: https://spotify.github.io/scio/Scio,-Scalding-and-Spark.html#scio-and-spark
sc.distCacheto download files periodically? My job needs to update local DBs every day or so and I’m wondering if there’s any logic I need to add or
initFnis called every time and I just can store last download time in a local var and update it when necessary?