Abstract:
Join us for a live demo featuring a real-time vector database ingestion use case. We demonstrate how to run Apache Flink jobs written in Python using Decodable's latest managed PyFlink offering. The PyFlink job reads records from an operational database (MySQL), transforms them into vector embeddings on the fly, and streams them into MongoDB used as a vector database to support RAG architectures with fresh data.
Repository: https://github.com/decodableco/examples/tree/main/pyflink-vector-embeddings