Tag
This blog post is a comprehensive guide to watermarks in Apache Flink, explaining their concepts, generation, propagation, and usage in Flink SQL and Table API.
This paper proposes MAS-DecStream, a decentralized scheduling framework for stream processing in mobile edge-cloud infrastructures, extending the Contract Net Protocol with LLM-assisted negotiation. Experiments show reduced latency violations and improved utility over rule-based baselines.
Explains the AT Protocol architecture through the lens of distributed systems engineering, covering the shift from SQL to NoSQL to stream processing, and how AT Protocol externalizes these services for a decentralized backend.