Megaphone: Latency-conscious state migration for distributed streaming dataflows

Moritz Hoffmann, Andrea Lattuada, Frank McSherry +3

We design and implement Megaphone, a data migration mechanism for stateful distributed dataflow engines with latency objectives. When compared to existing migration mechanisms, Meg…