Patch the identifiers (source/target) in the relations #125

This PR includes an extension of the oozie workflow responsible for the creation of the raw graph that optionally allows to run a phase where the identifiers included in the graph relations (source and target) can be updated with the values provided by a correspondence map (oldId -> newId).

In order to activate this phase, when running the raw_all workflow ensure to

set the flag shouldPatchRelations = true
set the path pointing to the HDFS location where the correspondence map is stored (idMappingPath). Note that the oozie workflow also checkes that the path exists

This PR includes an extension of the oozie workflow responsible for the creation of the `raw` graph that optionally allows to run a phase where the identifiers included in the graph relations (`source` and `target`) can be updated with the values provided by a correspondence map (`oldId -> newId`). In order to activate this phase, when running the `raw_all` workflow ensure to * set the flag `shouldPatchRelations = true` * set the path pointing to the HDFS location where the correspondence map is stored (`idMappingPath`). Note that the oozie workflow also checkes that the path exists

PR integrated also in the beta branch with e87e1805c4

PR integrated also in the `beta` branch with e87e1805c4280e9d8ed9be9f733d331401273118

One further fix added

patching relation identifier phase to be run at the end, i.e. includes also claimed relations

beta commit 5d08ad86ae
master commit e725c88ebb

One further fix added ```patching relation identifier phase to be run at the end, i.e. includes also claimed relations``` - `beta` commit 5d08ad86ae45478db3742fef51c7c0ae38f30e34 - `master` commit e725c88ebb6eedea235abfc07af932756c9e2397

 @ -0,0 +81,4 @@
         rels
                 .joinWith(idMapping, rels.col("source").equalTo(idMapping.col("oldId")), "full")
                 .filter((FilterFunction<Tuple2<Relation, RelationIdMapping>>) t -> Objects.nonNull(t._1()))

Labels Milestones

Patch the identifiers (source/target) in the relations #125

Reviewers

Step 1:

Step 2: