was by wangyue >
#12 in #spark
445KB 11K SLoC
High performance Stream Processing Framework
~37–51MB ~1M SLoC