1. A method of using an open station as a stream analysis operator container, the method is stored as instructions on a non-transitory computer readable media and executable by a processor for: packaging graph-structured stream transformations into a topology of a top-level dataflow process including stream transformation operators (STOs) on open stations, wherein the open stations each have a defined dataflow function having a higher level of abstraction with respect to the STOs contained in each open station such that the defined dataflow function of each open station encompass different types of specific STO application logic, facilitating the plugging in of specific types of STO application logic into the topology of the top-level dataflow process; and sending a tuple from one of the STOs to every other STO in the topology subscribed to a data stream of the tuple, and further comprising executing multiple STOs in parallel using a task property specifying a number of threads for running the multiple STOs.