From 1dc63de0eacdf6504bf0dee239aa0a1818b3e865 Mon Sep 17 00:00:00 2001 From: Liviu Popa Date: Mon, 5 Oct 2020 14:16:41 +0300 Subject: [PATCH] Vertical Lineage backend - skip condensation Signed-off-by: Liviu Popa --- .../janusconnector/graph/LineageGraphConnectorHelper.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/open-metadata-implementation/adapters/open-connectors/governance-daemon-connectors/open-lineage-connectors/open-lineage-janus-connector/src/main/java/org/odpi/openmetadata/openconnectors/governancedaemonconnectors/openlineageconnectors/janusconnector/graph/LineageGraphConnectorHelper.java b/open-metadata-implementation/adapters/open-connectors/governance-daemon-connectors/open-lineage-connectors/open-lineage-janus-connector/src/main/java/org/odpi/openmetadata/openconnectors/governancedaemonconnectors/openlineageconnectors/janusconnector/graph/LineageGraphConnectorHelper.java index 72993efd1a1..d1f91187a41 100644 --- a/open-metadata-implementation/adapters/open-connectors/governance-daemon-connectors/open-lineage-connectors/open-lineage-janus-connector/src/main/java/org/odpi/openmetadata/openconnectors/governancedaemonconnectors/openlineageconnectors/janusconnector/graph/LineageGraphConnectorHelper.java +++ b/open-metadata-implementation/adapters/open-connectors/governance-daemon-connectors/open-lineage-connectors/open-lineage-janus-connector/src/main/java/org/odpi/openmetadata/openconnectors/governancedaemonconnectors/openlineageconnectors/janusconnector/graph/LineageGraphConnectorHelper.java @@ -230,7 +230,7 @@ private Optional 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 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 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)); } /**