Merge pull request #3749 from lcpopa/master

Vertical Lineage backend - skip condensation
odpi · Oct 5, 2020 · 2166b76 · 2166b76
2 parents 763fda4 + 1dc63de
commit 2166b76
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...monconnectors/openlineageconnectors/janusconnector/graph/LineageGraphConnectorHelper.java b/...monconnectors/openlineageconnectors/janusconnector/graph/LineageGraphConnectorHelper.java
@@ -230,7 +230,7 @@ private Optional<LineageVerticesAndEdges> glossaryVerticalLineage(String guid) {
         Graph subGraph = (Graph) g.V().has(PROPERTY_KEY_ENTITY_GUID, guid).bothE(glossaryTermAndClassificationEdges)
                 .subgraph("s").cap("s").next();
 
-        return Optional.of(getLineageVerticesAndEdges(subGraph, false));
+        return Optional.of(getLineageVerticesAndEdges(subGraph, true));
     }
 
     /**
@@ -246,7 +246,7 @@ private Optional<LineageVerticesAndEdges> relationalColumnVerticalLineage(String
         Graph subGraph = (Graph) g.V().has(PROPERTY_KEY_ENTITY_GUID, guid).bothE(relationalColumnAndClassificationEdges)
                 .subgraph("s").cap("s").next();
 
-        return Optional.of(getLineageVerticesAndEdges(subGraph, false));
+        return Optional.of(getLineageVerticesAndEdges(subGraph, true));
     }
 
     /**
@@ -262,7 +262,7 @@ private Optional<LineageVerticesAndEdges> tabularColumnVerticalLineage(String gu
         Graph subGraph = (Graph) g.V().has(PROPERTY_KEY_ENTITY_GUID, guid).bothE(tabularColumnAndClassificationEdges)
                 .subgraph("s").bothV().inE(ASSET_SCHEMA_TYPE).subgraph("s").cap("s").next();
 
-        return Optional.of(getLineageVerticesAndEdges(subGraph, false));
+        return Optional.of(getLineageVerticesAndEdges(subGraph, true));
     }
 
     /**