yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-11-08 15:30:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(frontend): Extract lastModified field from downstream/upstream aspect (#1672)

Browse Source
This commit is contained in:
Kerem Sahin 2020-05-14 09:11:37 -07:00 committed by GitHub
parent fe3494c955
commit 0114d14ff9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
datahub-dao/src/main/java/com/linkedin/datahub/dao/table/LineageDao.java
View File

@ -36,7 +36,7 @@ public class LineageDao {
.collect(Collectors.toSet())); .collect(Collectors.toSet()));
return upstreamArray.stream() return upstreamArray.stream()
.map(us -> toLineageView(datasets.get(us.getDataset()), us.getType().name(), us.getAuditStamp().getActor().toString())) .map(us -> toLineageView(datasets.get(us.getDataset()), us.getType().name(), us.getAuditStamp()))
.collect(Collectors.toList()); .collect(Collectors.toList());
} }
@ -51,7 +51,7 @@ public class LineageDao {
.collect(Collectors.toSet())); .collect(Collectors.toSet()));
return downstreamArray.stream() return downstreamArray.stream()
.map(ds -> toLineageView(datasets.get(ds.getDataset()), ds.getType().name(), ds.getAuditStamp().getActor().toString())) .map(ds -> toLineageView(datasets.get(ds.getDataset()), ds.getType().name(), ds.getAuditStamp()))
.collect(Collectors.toList()); .collect(Collectors.toList());
} }
} }

12
datahub-dao/src/main/java/com/linkedin/datahub/util/DatasetUtil.java
View File

@ -1,5 +1,6 @@
package com.linkedin.datahub.util; package com.linkedin.datahub.util;
import com.linkedin.common.AuditStamp;
import com.linkedin.common.urn.DatasetUrn; import com.linkedin.common.urn.DatasetUrn;
import com.linkedin.datahub.models.view.DatasetView; import com.linkedin.datahub.models.view.DatasetView;
import com.linkedin.datahub.models.view.LineageView; import com.linkedin.datahub.models.view.LineageView;
@ -79,15 +80,18 @@ public class DatasetUtil {
* for the dataset in the lineage response * for the dataset in the lineage response
* @param dataset dataset * @param dataset dataset
* @param lineageType type of lineage * @param lineageType type of lineage
* @param actor lineage actor * @param auditStamp audit stamp
* @return LineageView * @return LineageView
*/ */
public static LineageView toLineageView(Dataset dataset, String lineageType, String actor) { public static LineageView toLineageView(Dataset dataset, String lineageType, AuditStamp auditStamp) {
LineageView view = new LineageView(); LineageView view = new LineageView();
view.setDataset(toDatasetView(dataset)); DatasetView datasetView = toDatasetView(dataset);
datasetView.setModifiedTime(auditStamp.getTime());
view.setDataset(datasetView);
view.setType(lineageType); view.setType(lineageType);
view.setActor(actor); view.setActor(auditStamp.getActor().toString());
return view; return view;
} }