def _write(self, str_buf):
    raise NotImplementedError("_write() not implemented in %s" % type(self))
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/src/mapreduce/output_writers.py/_RecordsPoolBase._write/original