SQL-based ingestion