Streaming RAG Pipeline

Implement a RAG pipeline that ingests streaming unstructured data, extracts component parts, enriches them, and enables chat-based retrieval with source linking.