INNER CODE UNIT · Python

mapper

ncbi/dbsnp · tutorials/hadoop_json_merge.py:52

    def mapper(self, _, line):

        data = json.loads(line)

        snp_id = data["refsnp_id"]

        merges = data["dbsnp1_merges"]

        for m in merges:
            values = (snp_id, m["merged_rsid"], m["revision"], m["merge_date"])
            print("\t".join(values))


if __name__ == '__main__':
    MRJsonProcessor.run()

View source record →