Query processing of stream objects using stream expansion

A method comprising:

• decoding, by at least one hardware processor, a query to obtain a first data processing operation and a first stream object, the first stream object associated with a view on a base table;
• performing a first stream expansion on the first stream object, the first stream expansion based on generating a second stream object on the base table;
• performing a second stream expansion of the second stream object, the second stream expansion based on replacing the second stream object with at least a second data processing operation;
• and
• executing the query based on completing the first data processing operation and the at least a second data processing operation.

A computer-storage medium comprising instructions that, when executed by one or more processors of a machine, configure the machine to perform operations comprising:

• decoding, by at least one hardware processor, a query to obtain a first data processing operation and a first stream object, the first stream object associated with a view on a base table;
• performing a first stream expansion on the first stream object, the first stream expansion based on generating a second stream object on the base table;
• performing a second stream expansion of the second stream object, the second stream expansion based on replacing the second stream object with at least a second data processing operation;
• and
• executing the query based on completing the first data processing operation and the at least a second data processing operation.