We need to implement a munge_dumps Airflow that invokes
org.wikidata.query.rdf.spark.transform.structureddata.dumps.WikibaseRDFDumpConverter
parametrized to read TTLs from S3 and write to HDFS in the wikidata namespace.
References
We need to implement a munge_dumps Airflow that invokes
org.wikidata.query.rdf.spark.transform.structureddata.dumps.WikibaseRDFDumpConverter
parametrized to read TTLs from S3 and write to HDFS in the wikidata namespace.
References
| Status | Subtype | Assigned | Task | ||
|---|---|---|---|---|---|
| Resolved | gmodena | T431253 [DE2.4.2] WDQS v2 Scaling | |||
| Open | gmodena | T440523 [DE2.6.3] Achieve Launch Readiness for GA | |||
| Stalled | gmodena | T422179 Set up regular bulk data ingestion and indexing pipeline | |||
| Resolved | gmodena | T428237 data-reload: spark processing jobs need to be orchestrated in the wikidata dag. | |||
| Resolved | gmodena | T429248 data-reload: munge_dumps task reads TTL data from S3 and writes to HDFS |
gmodena opened https://gitlab.wikimedia.org/repos/data-engineering/airflow-dags/-/merge_requests/2319
Draft: wikidata: orchestrate spark jobs for data preparation and transfer.