A Distributed Stream Computing Platform by erlang.