Job type Job Facet
Facet to contain job properties like:
processingTypewhich can beSTREAMINGorBATCH,integrationwhich can beSPARK|DBT|AIRFLOW|FLINK,jobTypewhich can beQUERY|COMMAND|DAG|TASK|JOB|MODEL.
Example:
{
...
"job": {
"facets": {
"jobType": {
"processingType": "BATCH",
"integration": "SPARK",
"jobType": "QUERY",
"_producer": "https://github.com/OpenLineage/OpenLineage/blob/v1-0-0/client",
"_schemaURL": "https://openlineage.io/spec/facets/2-0-2/JobTypeJobFacet.json"
}
}
...
}
The examples for specific integrations:
- Integration:
SPARK- Processing type:
STREAM|BATCH - Job type:
JOB|COMMAND
- Processing type:
- Integration:
AIRFLOW- Processing type:
BATCH - Job type:
DAG|TASK
- Processing type:
- Integration:
DBT- ProcessingType:
BATCH - JobType:
PROJECT|MODEL
- ProcessingType:
- Integration:
FLINK- Processing type:
STREAMING|BATCH - Job type:
JOB
- Processing type: