NR-347971 | OpenLineage event consumer writer

entity-types/agent-openlineage/definition.yml

@@ -0,0 +1,5 @@
+domain: AGENT
+type: OPENLINEAGE
+configuration:
+  entityExpirationTime: MANUAL
+  alertable: false

entity-types/dpo-dataset_versions/definition.yml

@@ -0,0 +1,27 @@
+domain: DPO
+type: DATASET_VERSIONS
+synthesis:
+  rules:
+  - compositeIdentifier:
+        separator: ":"
+        attributes:
+          - dataset.namespace
+          - dataset.name
+          - updatedAt
+    name: dataset.name
+    encodeIdentifierInGUID: true
+    conditions:
+    - attribute: dataset.name
+    tags:
+      dataset.namespace:
+        entityTagName: olin.dataset.namespace
+        multiValue: false
+      dataset.name:
+        entityTagName: olin.dataset.name
+        multiValue: false
+      dataset.updatedAt:
+        entityTagName: olin.dataset.updatedAt
+        multiValue: false
+configuration:
+  entityExpirationTime: MANUAL
+  alertable: true

entity-types/dpo-datasets/definition.yml

@@ -0,0 +1,23 @@
+domain: DPO
+type: DATASETS
+synthesis:
+  rules:
+  - compositeIdentifier:
+        separator: ":"
+        attributes:
+          - dataset.namespace
+          - dataset.name
+    name: dataset.name
+    encodeIdentifierInGUID: true
+    conditions:
+    - attribute: dataset.name
+    tags:
+      dataset.namespace:
+        entityTagName: olin.dataset.namespace
+        multiValue: false
+      dataset.name:
+        entityTagName: olin.dataset.name
+        multiValue: false
+configuration:
+  entityExpirationTime: MANUAL
+  alertable: true

entity-types/dpo-job_versions/definition.yml

@@ -0,0 +1,30 @@
+domain: DPO
+type: JOB_VERSIONS
+synthesis:
+  rules:
+  - compositeIdentifier:
+        separator: ":"
+        attributes:
+          - job.namespace
+          - job.name
+          - updatedAt
+    name: job.name
+    encodeIdentifierInGUID: true
+    conditions:
+    - attribute: job.name
+    tags:
+      job.namespace:
+        entityTagName: olin.job.namespace
+        multiValue: false
+      job.name:
+        entityTagName: olin.job.name
+        multiValue: false
+      job.updatedAt:
+        entityTagName: olin.job.updatedAt
+        multiValue: false
+      pipeline.name:
+        entityTagName: olin.pipeline.name
+        multiValue: false
+configuration:
+  entityExpirationTime: MANUAL
+  alertable: true

entity-types/dpo-jobs/definition.yml

@@ -0,0 +1,27 @@
+domain: DPO
+type: JOBS
+synthesis:
+  rules:
+  - compositeIdentifier:
+        separator: ":"
+        attributes:
+          - job.namespace
+          - job.name
+          - eventTime
+    name: job.name
+    encodeIdentifierInGUID: true
+    conditions:
+    - attribute: job.name
+    tags:
+      job.namespace:
+        entityTagName: olin.job.namespace
+        multiValue: false
+      job.name:
+        entityTagName: olin.job.name
+        multiValue: false
+      pipeline.name:
+        entityTagName: olin.pipeline.name
+        multiValue: false
+configuration:
+  entityExpirationTime: MANUAL
+  alertable: true

entity-types/dpo-pipelines/definition.yml

@@ -0,0 +1,23 @@
+domain: DPO
+type: PIPELINES
+synthesis:
+  rules:
+  - compositeIdentifier:
+        separator: ":"
+        attributes:
+          - pipeline.namespace
+          - pipeline.name
+    name: pipeline.name
+    encodeIdentifierInGUID: true
+    conditions:
+    - attribute: pipeline.name
+    tags:
+      pipeline.namespace:
+        entityTagName: olin.pipeline.namespace
+        multiValue: false
+      pipeline.name:
+        entityTagName: olin.pipeline.name
+        multiValue: false
+configuration:
+  entityExpirationTime: MANUAL
+  alertable: true