

@classmethod
def create(cls, mapreduce_state, shard_state):
    'Create new writer for a shard.\n\n    Args:\n      mapreduce_state: an instance of model.MapreduceState describing current\n      job. State can be modified.\n      shard_state: shard state.\n    '
    raise NotImplementedError(('create() not implemented in %s' % cls))

dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/ext/mapreduce/output_writers.py OutputWriter.create/original