Package org.odpi.openmetadata.adapters.connectors.integration.openlineage.postgres

package org.odpi.openmetadata.adapters.connectors.integration.openlineage.postgres

The PostgreSQL OpenLineage log store stores open lineage events, and a digest of their runs, datasets, data quality assertions and tests, in the PostgreSQL database schemas attached to the connector as catalog targets.

Related Packages

Package	Description
org.odpi.openmetadata.adapters.connectors.integration.openlineage	The open lineage integration connectors work with open lineage events and either process or distribute them.
org.odpi.openmetadata.adapters.connectors.integration.openlineage.controls	Provides the control objects (template types, configuration properties, deployed implementation types) used to configure Open Lineage Integration Connectors.
org.odpi.openmetadata.adapters.connectors.integration.openlineage.ffdc	FFDC stands for First Failure Data Capture.

Class	Description
PostgresOpenLineageEventDigest	PostgresOpenLineageEventDigest extracts the rows that an OpenLineage run event contributes to the digest tables of a PostgreSQL OpenLineage log store (see PostgresOpenLineageLogStoreSchema).
PostgresOpenLineageEventDigest.AssertionRow	A data quality assertion reported on an input dataset.
PostgresOpenLineageEventDigest.DatasetRow	A dataset read (I) or written (O) by the run.
PostgresOpenLineageEventDigest.RunRow	Contribution of the event to its run.
PostgresOpenLineageEventDigest.TestRow	A test reported in the run's test facet.
PostgresOpenLineageLogStoreCatalogTargetProcessor	Stores open lineage events in one PostgreSQL database schema.
PostgresOpenLineageLogStoreConfigurationProperty	PostgresOpenLineageLogStoreConfigurationProperty provides definitions for the configuration properties used with the PostgreSQL OpenLineage log store integration connector.
PostgresOpenLineageLogStoreConnector	PostgresOpenLineageLogStoreConnector stores the open lineage events published to the integration daemon in the PostgreSQL database schemas attached to it as catalog targets.
PostgresOpenLineageLogStoreProvider	PostgresOpenLineageLogStoreProvider is the connector provider for the PostgreSQL OpenLineage log store integration connector.
PostgresOpenLineageLogStoreSchema	PostgresOpenLineageLogStoreSchema defines the tables of a PostgreSQL OpenLineage log store and the SQL that writes, purges and reads them.
PostgresOpenLineageLogStoreWriter	PostgresOpenLineageLogStoreWriter issues the SQL that maintains one PostgreSQL OpenLineage log store: it creates the schema and tables, stores each event with its contribution to the digest in one transaction, and purges old records.