[graph cleaning] added missing case
This commit is contained in:
parent
dead87917f
commit
864f4051d3
|
@ -169,7 +169,6 @@ public class CleanGraphSparkJob {
|
|||
} else {
|
||||
save(cleaned_basic, outputPath);
|
||||
}
|
||||
|
||||
} else if (Boolean.TRUE.equals(ModelSupport.isSubClass(clazz, Result.class))) {
|
||||
|
||||
// load the hostedby mapping
|
||||
|
@ -191,6 +190,8 @@ public class CleanGraphSparkJob {
|
|||
Encoders.bean(clazz));
|
||||
|
||||
save(cleaned_deep, outputPath);
|
||||
} else {
|
||||
save(cleaned_basic, outputPath);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue