10. A non-transitory computer readable storage medium having instructions for causing a computer to execute a method, comprising: executing a continuous data stream process with three functions that include an extract, transform, load (ETL) process, an aggregation process, and reporting process; specifying the continuous data stream process with Structured Query Language (SQL) queries; executing the SQL queries at a database management system (DBMS) level, wherein the SQL queries include User Defined Functions (UDFs) that perform relational transformations like a relational operator since the UDFs include input values as relations and output values as relations; and identifying stations with triggering conditions and outgoing pipes, the outgoing pipes defined with a relation schema for type-preservation and with a stream key for identifying stream elements, wherein relations returned from the UDF are replicated to multiple pipes for multiple destination stations.
10. A non-transitory computer readable storage medium having instructions for causing a computer to execute a method, comprising: executing a continuous data stream process with three functions that include an extract, transform, load (ETL) process, an aggregation process, and reporting process; specifying the continuous data stream process with Structured Query Language (SQL) queries; executing the SQL queries at a database management system (DBMS) level, wherein the SQL queries include User Defined Functions (UDFs) that perform relational transformations like a relational operator since the UDFs include input values as relations and output values as relations; and identifying stations with triggering conditions and outgoing pipes, the outgoing pipes defined with a relation schema for type-preservation and with a stream key for identifying stream elements, wherein relations returned from the UDF are replicated to multiple pipes for multiple destination stations. 11. The non-transitory computer readable storage medium of claim 10 , wherein the ETL process, the aggregation process, and the reporting process execute in different cycles with the ETL process executing more frequently than the reporting process.