Description
Got this cool idea from one of my customers: allow people to write one-liner counter increment functions on top of Scrunch, ala:
val pc: PCollection[S] = ...
pc.map(...)
.increment("CounterGroup", "CounterValue")
.incrementIf(x => x.foo == "bar")("CounterGroup", "CheckBar")
etc.