If we did:
```scala
pipe.incrementCounters{ t => Map(("myjob" -> "items"), 1L)}
```
you have to keep making functions to extract the counter rather than doing the operation in a collect, flatMap, map, etc...