Introduce new ingestion pipeline structure, implement internal Likes with it.