Denormalize namespace name to job table

api/src/main/java/marquez/db/JobDao.java

@@ -35,6 +35,7 @@ public interface JobDao {
           + "created_at, "
           + "updated_at, "
           + "namespace_uuid, "
+          + "namespace_name, "
           + "name, "
           + "description, "
           + "current_version_uuid"
@@ -44,6 +45,7 @@ public interface JobDao {
           + ":createdAt, "
           + ":updatedAt, "
           + ":namespaceUuid, "
+          + ":namespaceName, "
           + ":name, "
           + ":description, "
           + ":currentVersionUuid)")
@@ -80,9 +82,8 @@ public interface JobDao {
   Optional<JobRow> find(String namespaceName, String jobName);
 
   @SqlQuery(
-      "SELECT j.*, n.name AS namespace_name FROM jobs AS j "
-          + "INNER JOIN namespaces AS n "
-          + "  ON (n.name = :namespaceName AND j.namespace_uuid = n.uuid) "
+      "SELECT j.* FROM jobs AS j "
+          + "WHERE namespace_name = :namespaceName "
           + "ORDER BY j.name "
           + "LIMIT :limit OFFSET :offset")
   List<JobRow> findAll(String namespaceName, int limit, int offset);
@@ -97,6 +98,7 @@ public interface JobDao {
           + "created_at, "
           + "updated_at, "
           + "namespace_uuid, "
+          + "namespace_name, "
           + "name, "
           + "description "
           + ") VALUES ( "
@@ -105,6 +107,7 @@ public interface JobDao {
           + ":now, "
           + ":now, "
           + ":namespaceUuid, "
+          + ":namespaceName, "
           + ":name, "
           + ":description "
           + ") ON CONFLICT (name, namespace_uuid) DO "
@@ -114,5 +117,11 @@ public interface JobDao {
           + "description = EXCLUDED.description "
           + "RETURNING *")
   JobRow upsert(
-      UUID uuid, JobType type, Instant now, UUID namespaceUuid, String name, String description);
+      UUID uuid,
+      JobType type,
+      Instant now,
+      UUID namespaceUuid,
+      String namespaceName,
+      String name,
+      String description);
 }

api/src/main/java/marquez/db/JobVersionDao.java

@@ -98,7 +98,7 @@ default void updateOutputs(UUID versionUuid, UUID outputUuid) {
   void updateLatestRun(UUID rowUuid, Instant updatedAt, UUID latestRunUuid);
 
   final String EXTENDED_SELECT =
-      "SELECT j.namespace_uuid, jv.*, jc.uuid AS job_context_uuid, jc.context, n.name as namespace_name, j.name, "
+      "SELECT j.namespace_uuid, jv.*, jc.uuid AS job_context_uuid, jc.context, j.namespace_name, j.name, "
           + "ARRAY(SELECT dataset_uuid "
           + "      FROM job_versions_io_mapping "
           + "      WHERE job_version_uuid = jv.uuid AND "
@@ -110,8 +110,6 @@ default void updateOutputs(UUID versionUuid, UUID outputUuid) {
           + "FROM job_versions AS jv "
           + "INNER JOIN jobs AS j "
           + "  ON j.uuid = jv.job_uuid "
-          + "INNER JOIN namespaces AS n "
-          + "  ON j.namespace_uuid = n.uuid "
           + "INNER JOIN job_contexts AS jc "
           + "  ON job_context_uuid = jc.uuid ";
 
@@ -120,7 +118,7 @@ default void updateOutputs(UUID versionUuid, UUID outputUuid) {
 
   @SqlQuery(
       EXTENDED_SELECT
-          + "WHERE n.name = :namespaceName AND j.name = :jobName AND j.current_version_uuid = jv.uuid "
+          + "WHERE j.namespace_name = :namespaceName AND j.name = :jobName AND j.current_version_uuid = jv.uuid "
           + "ORDER BY created_at DESC "
           + "LIMIT 1")
   Optional<ExtendedJobVersionRow> findLatest(String namespaceName, String jobName);
@@ -130,7 +128,7 @@ default void updateOutputs(UUID versionUuid, UUID outputUuid) {
 
   @SqlQuery(
       EXTENDED_SELECT
-          + "WHERE n.name = :namespaceName AND j.name = :jobName "
+          + "WHERE j.namespace_name = :namespaceName AND j.name = :jobName "
           + "ORDER BY created_at DESC "
           + "LIMIT :limit OFFSET :offset")
   List<ExtendedJobVersionRow> findAll(String namespaceName, String jobName, int limit, int offset);

api/src/main/java/marquez/db/OpenLineageDao.java

@@ -106,6 +106,7 @@ default UpdateLineageRow updateMarquezModel(LineageEvent event) {
             getJobType(event.getJob()),
             now,
             namespace.getUuid(),
+            namespace.getName(),
             event.getJob().getName(),
             description);
     bag.setJob(job);

api/src/main/java/marquez/db/RunDao.java

@@ -151,8 +151,7 @@ default void updateJobVersionUuid(UUID rowUuid, Instant updatedAt, UUID jobVersi
       SELECT_RUN
           + "INNER JOIN job_versions AS jv ON r.job_version_uuid = jv.uuid "
           + "INNER JOIN jobs AS j ON jv.job_uuid = j.uuid "
-          + "INNER JOIN namespaces AS n ON j.namespace_uuid = n.uuid "
-          + "WHERE n.name = :namespace and j.name = :jobName "
+          + "WHERE j.namespace_name = :namespace and j.name = :jobName "
           + "ORDER BY r.created_at DESC "
           + "LIMIT :limit OFFSET :offset")
   List<ExtendedRunRow> findAll(String namespace, String jobName, int limit, int offset);

api/src/main/resources/marquez/db/migration/V20__alter_jobs_to_add_namespace_name.sql

@@ -0,0 +1,2 @@
+ALTER TABLE jobs ADD namespace_name VARCHAR(255);
+UPDATE jobs SET namespace_name = namespaces.name FROM namespaces WHERE jobs.namespace_uuid = namespaces.uuid;