Distributed realtime computation system to process data streams