def mr_writer(job, outputs, output_stream,<EOL>stderr=sys.stderr, dumps=core.dumps):
for output in outputs:<EOL><INDENT>try:<EOL><INDENT>print(dumps(output), file=output_stream)<EOL><DEDENT>except core.ParseError as e:<EOL><INDENT>print(e, file=stderr)<EOL>raise<EOL><DEDENT><DEDENT>
Writes a stream of json serialised pyschema Records to a file object

    Can be used as job.writer in luigi.hadoop.JobTask