1. An apparatus comprising: at least one processor; a memory coupled to the at least one processor; and a stream data node residing in the memory that receives streamed data from at least one data source, dynamically reduces the streamed data using a filter mechanism that specifies data to exclude from the streamed data according to at least one filter criterion as the streamed data is received before storing the streamed data in a database, and delivers the reduced streamed data when an external request is received, wherein the stream data node is part of a query execution data structure, and wherein the stream data node delivers the reduced streamed data when requested by a different node in the query execution data structure.