--- 2017.11.28
动机
有一批相似的函数，代码逻辑是重复的，只有几个参数是不同的；比如在bigflow里输出counter，counter.increase("my_counter_a") 需要定义成函数：
def my_counter_a(r):
counter.increase("my_counter_a")
return r
my_pcollection.map(my_counter_a)
当要输出很多counter时，就很烦了。
解法
可以定义一个Callable对象，在运行时生成函数对象（其实类似C++里的仿函数的用法）：
from collections import Callable
from bigflow import counter
class Counter(Callable):
def __init__(self, counter_name):
self.counter_name = counter_name
def __call__(self, record):
counter.increase(self.counter_name)
return record
my_pcollection.map(Counter("my_counter_a"))
collections.Callable 的实现在 lib/python2.7/_abcoll.py, 使用了 metaclass，后续研究一下再补充。
---2017.11.29
今天发现Callable对象跟function还是不一样，不能用在pcollection.map()里；
又想了另一个方法:
def _do_counter(record, counter_name):
counter.increase(counter_name)
return record
