pyschema_extensions/luigi.py
def mr_reader(job, input_stream, loads=core.loads):
    """ Converts a file object with json serialised pyschema records
        to a stream of pyschema objects

    Can be used as job.reader in luigi.hadoop.JobTask
    """
    for line in input_stream:
        yield loads(line),
def mr_reader(job, input_stream, loads=core.loads):
    for line in input_stream:
        yield loads(line),
def mr_reader ( job , input_stream , loads = core . loads ) : for line in input_stream : yield loads ( line ) ,
Converts a file object with json serialised pyschema records
        to a stream of pyschema objects

    Can be used as job.reader in luigi.hadoop.JobTask
Converts a file object with json serialised pyschema records to a stream of pyschema objects