scalding-counters-example

Define the counter

class ScaldingCounterExampleJob(args : Args) extends Job(args) {
  val stat = Stat("alice-counter")

Use the counter

  TypedPipe.from("is alice really alice ?".split(" "))
    .flatMap {
      line => {
        stat.inc

Run the example

Main class: com.twitter.scalding.Tool
VM options: -Xmx1024m
Program arguments: ScaldingCounterExampleJob --local --output output.txt

See resulting counter

Dumping custom counters:
alice-counter	5

Clone the full working example