Skip to content

Instantly share code, notes, and snippets.

@MarkRoddy

MarkRoddy/pig_counters.py

Created November 8, 2013 00:56
Show Gist options
  • Save MarkRoddy/7364543 to your computer and use it in GitHub Desktop.
Save MarkRoddy/7364543 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
pig_counters.py
from org.apache.pig.tools.pigstats import PigStatusReporter
def increment(group, name, value = 1):
status_reporter = PigStatusReporter.getInstance()
if status_reporter != None:
counter = status_reporter.getCounter(group, name)
if counter:
counter.increment(value);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment