Project

General

Profile

« Previous | Next » 

Revision 58659

added mapping for externalreferences

View differences:

modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/dataexport/ProtoConverter.java
55 55
            case result:
56 56
                final Result r = convertResult(oaf);
57 57
                r.setInstance(convertInstances(oaf));
58
                r.setExternalReference(convertExternalRefs(oaf));
58 59
                return r;
59 60
            case project:
60 61
                return convertProject(oaf);
......
67 68
        }
68 69
    }
69 70

  
71
    private static List<ExternalReference> convertExternalRefs(OafProtos.Oaf oaf) {
72
        ResultProtos.Result r = oaf.getEntity().getResult();
73
        if (r.getExternalReferenceCount() > 0) {
74
            return r.getExternalReferenceList()
75
                    .stream()
76
                    .map(e -> convertExtRef(e))
77
                    .collect(Collectors.toList());
78
        }
79
        return Lists.newArrayList();
80
    }
81

  
82
    private static ExternalReference convertExtRef(ResultProtos.Result.ExternalReference e) {
83
        ExternalReference ex = new ExternalReference();
84
        ex.setUrl(e.getUrl());
85
        ex.setSitename(e.getSitename());
86
        ex.setRefidentifier(e.getRefidentifier());
87
        ex.setQuery(e.getQuery());
88
        ex.setQualifier(mapQualifier(e.getQualifier()));
89
        ex.setLabel(e.getLabel());
90
        ex.setDescription(e.getDescription());
91
        ex.setDataInfo(ex.getDataInfo());
92
        return ex;
93
    }
94

  
70 95
    private static List<Instance> convertInstances(OafProtos.Oaf oaf) {
71 96

  
72 97
        final ResultProtos.Result r = oaf.getEntity().getResult();

Also available in: Unified diff