Compare commits
No commits in common. "4bb504e693927a2e3aae2cb65ca9d91833e8111a" and "2c4440951f3f518ce617cdae9700620f41d9d0bf" have entirely different histories.
4bb504e693
...
2c4440951f
|
@ -111,12 +111,12 @@ public class SparkAtomicActionUsageJob implements Serializable {
|
|||
resultModel
|
||||
.joinWith(datasource, resultModel.col("datasourceId").equalTo(datasource.col("id")), "left")
|
||||
.map((MapFunction<Tuple2<UsageStatsResultModel, Datasource>, UsageStatsResultModel>) t2 -> {
|
||||
UsageStatsResultModel usrm = t2._1();
|
||||
if(Optional.ofNullable(t2._2()).isPresent())
|
||||
usrm.setDatasourceId(usrm.getDatasourceId() + "||" + t2._2().getOfficialname().getValue());
|
||||
else
|
||||
usrm.setDatasourceId(usrm.getDatasourceId() + "||NO_MATCH_FOUND");
|
||||
return usrm;
|
||||
return usrm;
|
||||
}, Encoders.bean(UsageStatsResultModel.class))
|
||||
.write()
|
||||
.mode(SaveMode.Overwrite)
|
||||
|
|
Loading…
Reference in New Issue