forked from D-Net/dnet-hadoop
[BulkTagging] revert it
This commit is contained in:
parent
8e8933d41a
commit
c5a863132c
|
@ -126,9 +126,6 @@ public class SparkBulkTagJob {
|
||||||
// TODO remove this hack as soon as the values fixed by this method will be provided as NON null
|
// TODO remove this hack as soon as the values fixed by this method will be provided as NON null
|
||||||
private static <R extends Result> MapFunction<R, R> patchResult() {
|
private static <R extends Result> MapFunction<R, R> patchResult() {
|
||||||
return r -> {
|
return r -> {
|
||||||
if(r.getDataInfo() == null){
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
if (r.getDataInfo().getDeletedbyinference() == null) {
|
if (r.getDataInfo().getDeletedbyinference() == null) {
|
||||||
r.getDataInfo().setDeletedbyinference(false);
|
r.getDataInfo().setDeletedbyinference(false);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue