diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java index 9026c4f36da..e9fc52760ec 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java @@ -307,6 +307,7 @@ public class LineageRepository { "fromChildEntityFQN", "toChildEntityFQN", "pipelineName", + "pipelineDisplayName", "pipelineType", "pipelineDescription", "pipelineOwners", @@ -355,6 +356,7 @@ public class LineageRepository { "", "", "", + "", ""); LOG.debug( "Exported ColumnMapping: from='{}', to='{}'", @@ -364,7 +366,7 @@ public class LineageRepository { } else if (!pipeline.isMissingNode() && !pipeline.isNull()) { writePipelineRow(csvWriter, baseRow, pipeline); } else { - writeCsvRow(csvWriter, baseRow, "", "", "", "", "", "", "", "", ""); + writeCsvRow(csvWriter, baseRow, "", "", "", "", "", "", "", "", "", ""); } } csvWriter.close(); @@ -377,6 +379,7 @@ public class LineageRepository { private void writePipelineRow( CSVWriter csvWriter, Map baseRow, JsonNode pipeline) { String pipelineName = getText(pipeline, "name"); + String pipelineDisplayName = getText(pipeline, "displayName"); String pipelineType = getText(pipeline, "serviceType"); String pipelineDescription = getText(pipeline, "description"); String pipelineOwners = getOwners(pipeline.path("owners")); @@ -390,6 +393,7 @@ public class LineageRepository { "", "", pipelineName, + pipelineDisplayName, pipelineType, pipelineDescription, pipelineOwners, @@ -405,6 +409,7 @@ public class LineageRepository { String fromChildFQN, String toChildFQN, String pipelineName, + String pipelineDisplayName, String pipelineType, String pipelineDescription, String pipelineOwners, @@ -425,6 +430,7 @@ public class LineageRepository { fromChildFQN, toChildFQN, pipelineName, + pipelineDisplayName, pipelineType, pipelineDescription, pipelineOwners, @@ -531,6 +537,7 @@ public class LineageRepository { addField(recordList, getStringOrNull(edge, "description")); addField(recordList, getStringOrNull(edge, "pipeline", "id")); addField(recordList, getStringOrNull(edge, "pipeline", "fullyQualifiedName")); + addField(recordList, getStringOrNull(edge, "pipeline", "displayName")); addField(recordList, processColumnLineage(edge)); addField(recordList, getStringOrNull(edge, "sqlQuery")); addField(recordList, getStringOrNull(edge, "source")); diff --git a/openmetadata-service/src/main/resources/json/data/lineage/lineageCsvDocumentation.json b/openmetadata-service/src/main/resources/json/data/lineage/lineageCsvDocumentation.json index 2ee9fd6ee5a..0f45e7a8796 100644 --- a/openmetadata-service/src/main/resources/json/data/lineage/lineageCsvDocumentation.json +++ b/openmetadata-service/src/main/resources/json/data/lineage/lineageCsvDocumentation.json @@ -73,6 +73,14 @@ "`Airflow.transformation_pipeline`" ] }, + { + "name": "pipelineDisplayName", + "required": false, + "description": "Diplaay Name of the pipeline involved in lineage", + "examples": [ + "`Airflow.Test`" + ] + }, { "name": "columnLineage", "required": false,