pyschema_extensions/luigi.py
def mr_writer(job, outputs, output_stream,
              stderr=sys.stderr, dumps=core.dumps):
    """ Writes a stream of json serialised pyschema Records to a file object

    Can be used as job.writer in luigi.hadoop.JobTask
    """
    for output in outputs:
        try:
            print >> output_stream, dumps(output)
        except core.ParseError, e:
            print >> stderr, e
            raise
def mr_writer(job, outputs, output_stream,
              stderr=sys.stderr, dumps=core.dumps):
    for output in outputs:
        try:
            print >> output_stream, dumps(output)
        except core.ParseError, e:
            print >> stderr, e
            raise
def mr_writer ( job , outputs , output_stream , stderr = sys . stderr , dumps = core . dumps ) : for output in outputs : try : print >> output_stream , dumps ( output ) except core . ParseError , e : print >> stderr , e raise
Writes a stream of json serialised pyschema Records to a file object

    Can be used as job.writer in luigi.hadoop.JobTask
Writes a stream of json serialised pyschema Records to a file object