updated log to add subentity

This commit is contained in:
Sandro La Bruzzo 2023-06-28 13:36:05 +02:00
parent ed7e2ab6d1
commit 9963fd6d29
1 changed files with 1 additions and 1 deletions

View File

@ -117,7 +117,7 @@ public class SparkCreateSimRels extends AbstractSparkAction {
saveParquet(simRels, outputPath, SaveMode.Overwrite);
final long end = System.currentTimeMillis();
if (StringUtils.isNotBlank(dfLogPath)) {
final DedupLogModel model = new DedupLogModel(runTag, dedupConf.toString(), entity, start, end,
final DedupLogModel model = new DedupLogModel(runTag, dedupConf.toString(), subEntity, start, end,
end - start);
new DedupLogWriter(dfLogPath).appendLog(model, spark);