US 12,242,457 B2
Query processing of stream objects using stream expansion
Istvan Cseri, Seattle, WA (US); Tyler Jones, Redwood City, CA (US); Daniel Mills, Seattle, WA (US); and Daniel E. Sotolongo, Seattle, WA (US)
Assigned to Snowflake Inc., Bozeman, MT (US)
Filed by Snowflake Inc., Bozeman, MT (US)
Filed on Aug. 31, 2023, as Appl. No. 18/459,256.
Application 18/459,256 is a continuation of application No. 18/048,912, filed on Oct. 24, 2022, granted, now 11,860,850.
Application 18/048,912 is a continuation of application No. 17/650,604, filed on Feb. 10, 2022, granted, now 11,514,023.
Application 17/650,604 is a continuation of application No. 17/460,974, filed on Aug. 30, 2021, granted, now 11,301,451.
Prior Publication US 2023/0418807 A1, Dec. 28, 2023
This patent is subject to a terminal disclaimer.
Int. Cl. G06F 16/23 (2019.01); G06F 16/22 (2019.01); G06F 16/2455 (2019.01); G06F 16/27 (2019.01)
CPC G06F 16/2358 (2019.01) [G06F 16/2282 (2019.01); G06F 16/2456 (2019.01); G06F 16/24568 (2019.01); G06F 16/278 (2019.01)] 30 Claims
OG exemplary drawing
 
1. A system comprising:
at least one hardware processor; and
at least one memory storing instructions that cause the at least one hardware processor to perform operations comprising:
decoding a query to obtain a first query plan with a first data processing operation and a first stream object, the first stream object in the first query plan associated with a view on a base table;
performing a first stream expansion on the first stream object to generate a second query plan, the first stream expansion based on generating a second stream object on the base table within the second query plan;
performing a second stream expansion of the second stream object within the second query plan, 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.