A scalable distributed stream join system - View it on GitHub