lightweight distributed stream processor