Embodiments for speculative execution in a distributed streaming system by a processor. Incoming data from a data packet may be shared with one or more applications for immediate processing upon the incoming data becoming available on an input/output (I/O) interface to enable overlapping of computation and communication in the distributed streaming system. A validity of the shared incoming data may be indicated to the one or more applications.