Create and Emit 'OpenLineage' Events


[Up] [Top]

Documentation for package ‘openlineage’ version 0.1.0

Help Pages

openlineage-package Create and Emit OpenLineage Events
AccumulatingTransport Local OpenLineage transports
as_openlineage_list Convert an OpenLineage value to its wire representation
ConsoleTransport Local OpenLineage transports
Dataset OpenLineage datasets
datasets OpenLineage datasets
dataset_facets Typed dataset facets
DatasourceDatasetFacet Typed dataset facets
EmissionPattern Typed job facets
ErrorMessageRunFacet Typed run facets
HttpTransport Synchronous HTTP transport
InputDataset OpenLineage datasets
InputStatisticsInputDatasetFacet Input and output statistics facets
io_statistics_facets Input and output statistics facets
Job OpenLineage job
JobTypeJobFacet Typed job facets
job_facets Typed job facets
local_transports Local OpenLineage transports
new_event_time Format an OpenLineage event time
new_run_id Generate a run identifier
NominalTimeRunFacet Typed run facets
NoopTransport Local OpenLineage transports
ol_facet Create a generic OpenLineage facet
ol_tag Create an OpenLineage tag
openlineage Create and Emit OpenLineage Events
OpenLineageClient OpenLineage client
openlineage_constants OpenLineage protocol constants
OPENLINEAGE_PRODUCER OpenLineage protocol constants
OPENLINEAGE_RUN_EVENT_SCHEMA_URL OpenLineage protocol constants
OPENLINEAGE_SCHEMA_URL OpenLineage protocol constants
OPENLINEAGE_SCHEMA_VERSION OpenLineage protocol constants
OutputDataset OpenLineage datasets
OutputStatisticsOutputDatasetFacet Input and output statistics facets
ParentRunFacet Typed run facets
ProcessingEngineRunFacet Typed run facets
Run OpenLineage run
RunEvent OpenLineage run event
RunState OpenLineage run state
run_facets Typed run facets
SchemaDatasetFacet Typed dataset facets
SchemaField Typed dataset facets
SourceCodeLocationJobFacet Typed job facets
SQLJobFacet Typed job facets
TagsDatasetFacet Typed tags facets
TagsJobFacet Typed tags facets
TagsRunFacet Typed tags facets
tags_facets Typed tags facets
to_openlineage_json Serialize an OpenLineage value to JSON