Uploaded image for project: 'Crunch (Retired)'
  1. Crunch (Retired)
  2. CRUNCH-398

Add increment and incrementIf functions to Scrunch APIs

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 0.10.0, 0.8.3
    • Scrunch
    • None

    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.

      Attachments

        1. CRUNCH-398b.patch
          11 kB
          Josh Wills
        2. CRUNCH-398.patch
          11 kB
          Josh Wills

        Activity

          People

            Unassigned Unassigned
            jwills Josh Wills
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment