Package org.odpi.openmetadata.frameworks.integration.openlineage
package org.odpi.openmetadata.frameworks.integration.openlineage
Interfaces for integrating with open lineage events
-
ClassDescriptionThis class represents the catalog dataset facet.This class represents the columnLineage dataset facet.This class represents the input fields (and transformation) that produce a single output field in the columnLineage dataset facet.This class represents an input field that contributes to an output field in the columnLineage dataset facet.This class represents a transformation applied to an input field in the columnLineage dataset facet.This class represents the dataQualityAssertions input dataset facet.This class represents a single data quality assertion evaluated against an input dataset.This class represents the data quality metrics for a single column of a dataset.This class represents the dataQualityMetrics dataset facet.This class represents the dataQualityMetrics input dataset facet.This class represents the content of an OpenLineage dataset event.This class represents a dataset facet from the OpenLineage standard spec https://openlineage.io/spec/2-0-2/OpenLineage.json#/$defs/DatasetFacet.This class represents the map of dataset facets for a dataset.This class represents the datasetType dataset facet.This class represents the version dataset facet.This class represents the dataSource dataset facet.This class represents the documentation dataset facet.This class represents the documentation job facet.This class represents the environmentVariables run facet.This class represents a single environment variable captured in the environmentVariables run facet.This class represents the errorMessage run facet.OpenLineageEventListener is the interface implemented by integration connectors that wish to receive OpenLineage events published through the integration daemon.This class represents the executionParameters run facet.This class represents a single parameter passed to the job at runtime.This class represents the externalQuery run facet.This class represents the extractionError run facet.This class represents a single error that occurred while OpenLineage was extracting lineage for a task in the run.This class represents the common header for facets in the OpenLineage standard spec https://openlineage.io/spec/2-0-2/OpenLineage.json#/$defs/BaseFacet.This class represents the gcp_composer_job job facet registered by Google Cloud Composer.This class represents the gcp_composer_run run facet registered by Google Cloud Composer.This class represents the gcp_dataproc run facet registered by Google Cloud Dataproc.This class represents the gcp_lineage job facet registered by Google Cloud Data Lineage.This class represents the origin of a job in the gcp_lineage job facet.This class represents the hierarchy dataset facet.This class represents a single level in the hierarchy dataset facet, for example DATABASE, SCHEMA or TABLE.This class represents the icebergCommitReport output dataset facet registered by Apache Iceberg.This class represents the commit metrics reported by Apache Iceberg for a write to a table.This class represents the icebergScanReport input dataset facet registered by Apache Iceberg.This class represents the scan metrics reported by Apache Iceberg for a read of a table.This class represents the content of an open lineage input data set as defined in JSON spec https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json.This class represents an input dataset facet (a facet describing the data read from a dataset by a particular run) from the OpenLineage standard spec https://openlineage.io/spec/2-0-2/OpenLineage.json#/$defs/InputDatasetFacet.This class represents the map of input dataset facets for an input dataset.This class represents the inputStatistics input dataset facet.This class represents the subset input dataset facet.This class represents the content of an open lineage job as defined in JSON spec https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json.This class represents the jobDependencies run facet.This class represents a single upstream or downstream job dependency.This class represents the identity of a job referenced by the jobDependencies run facet.This class represents the identity of a run referenced by the jobDependencies run facet.This class represents the content of an OpenLineage job event.This class represents a job facet from the OpenLineage standard spec https://openlineage.io/spec/2-0-2/OpenLineage.json#/$defs/JobFacet.This class represents the map of job facets for a job.This class represents the jobType job facet.This class represents how and what a job emits in its OpenLineage events.This class represents the lifecycleStateChange dataset facet.This class represents the previous identity of a dataset that has been renamed.This class represents the lineage dataset facet.This class represents a target entity (dataset or job) and the sources that feed it, from the lineage job facet.This class represents the source inputs that feed a single target field in the lineage facets.This class represents a source entity (dataset, dataset field or job) feeding a target in the lineage facets.This class represents the lineage job facet.This class represents a transformation applied to source data on its way to a target in the lineage facets.OpenLineageListenerManager is the interface used by integration connectors to register for, and publish, OpenLineage events within an integration daemon.This class represents the nominalTime run facet.This class represents the content of an open lineage output data set as defined out JSON spec https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json.This class represents an output dataset facet (a facet describing the data written to a dataset by a particular run) from the OpenLineage standard spec https://openlineage.io/spec/2-0-2/OpenLineage.json#/$defs/OutputDatasetFacet.This class represents the map of output dataset facets for an output dataset.This class represents the outputStatistics output dataset facet.This class represents the subset output dataset facet.This class represents the ownership dataset facet.This class represents a single owner of a dataset.This class represents the ownership job facet.This class represents a single owner of a job.This class represents the parent run facet.This class represents the identity of a parent (or root) job referenced from the parent run facet.This class represents the root run and job of a nested hierarchy of runs.This class represents the identity of a parent (or root) run referenced from the parent run facet.This class represents the processing_engine run facet.This class represents the content of an open lineage run event as defined in JSON spec https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json.This class represents the content of an open lineage run event as defined in JSON spec https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json.This class represents a run facet from the OpenLineage standard spec https://openlineage.io/spec/2-0-2/OpenLineage.json#/$defs/RunFacet.This class represents the map of run facets for a run.This class represents the schema dataset facet.This class represents a single field in the schema dataset facet.This class represents the sourceCode job facet.This class represents the sourceCodeLocation job facet.This class represents the sql job facet.This class represents a dataset described independently of any run, as carried by an OpenLineage dataset event.This class represents the storage dataset facet.This class represents the symlinks dataset facet.This class represents an alternative identifier (symlink) for a dataset.This class represents the tags dataset facet.This class represents a single tag applied to a dataset, or to a field within it.This class represents the tags job facet.This class represents a single tag applied to a job.This class represents the tags run facet.This class represents a single tag applied to a run.This class represents the test run facet.This class represents the outcome of a single test executed during a run.