

def __call__(self, context):
    'Execute operation.\n\n    Args:\n      context: mapreduce context as context.Context.\n    '
    context.counters.increment(self.counter_name, self.delta)

dataset/ETHPy150Open livid/v2ex/mapreduce/operation/counters.py Increment.__call__/original