公开(公告)号：US20200334230A1

公开(公告)日：2020-10-22

申请号：US16385720

申请日：2019-04-16

Applicant: Snowflake Inc.

Inventor： Subramanian Muralidhar ,  Benoit Dageville ,  Thierry Cruanes ,  Nileema Shingte ,  Saurin Shah ,  Torsten Grabs ,  Istvan Cseri

IPC: G06F16/23 ,  G06F16/25 ,  G06F16/248 ,  G06F16/2458 ,  G06F3/06

Abstract: Systems, methods, and devices for generating a materialized view over an external table. A method includes connecting a database platform to an external table such that the database platform has read access for the external table and does not have write access for the external table. The method includes generating, by the database platform, a materialized view over the external table. The method includes receiving a notification that a modification has been made to the external table, the modification comprising one or more of an addition of a file, a deletion of a file, or an update to a file in a source location for the external table. The method includes, in response to the external table being modified, refreshing the materialized view such that the materialized view comprises an accurate representation of the external table.

公开(公告)号：US20200327144A1

公开(公告)日：2020-10-15

申请号：US16913215

申请日：2020-06-26

Applicant: Snowflake Inc.

Inventor： Thierry Cruanes ,  Benoit Dageville ,  Allison Waingold Lee

IPC: G06F16/27 ,  G06F16/22 ,  G06F16/2453 ,  G06F16/21 ,  G06F16/182 ,  H04L29/08 ,  G06F16/14 ,  G06F9/50 ,  G06F9/48 ,  G06F16/951 ,  G06F16/9535 ,  G06F16/23 ,  G06F16/2455 ,  G06F16/2458

Abstract: A system and method for managing data storage and data access with querying data in a distributed system without buffering the results on intermediate operations in disk storage.

公开(公告)号：US10795914B2

公开(公告)日：2020-10-06

申请号：US16862458

申请日：2020-04-29

Applicant: Snowflake Inc.

Inventor： Thierry Cruanes ,  Benoit Dageville ,  Allison Waingold Lee

IPC: G06F15/16 ,  G06F16/27 ,  G06F9/50 ,  H04L29/08 ,  G06F9/48 ,  G06F16/2455 ,  G06F16/2453 ,  G06F16/9535 ,  G06F16/2458 ,  G06F16/23 ,  G06F16/182 ,  G06F16/951 ,  G06F16/22 ,  G06F16/21 ,  G06F16/14

Abstract: A system and method for managing data storage and data access with querying data in a distributed system without buffering the results on intermediate operations in disk storage.

公开(公告)号：US10783271B1

公开(公告)日：2020-09-22

申请号：US16902266

申请日：2020-06-16

Applicant: Snowflake Inc.

Inventor： Justin Langseth ,  Matthew J. Glickman ,  Christian Kleinerman ,  Robert Muglia ,  Daniel Freundel ,  Thierry Cruanes ,  Allison Waingold Lee

IPC: G06F21/00 ,  G06F21/62 ,  G06F16/2455 ,  H04L9/32

Abstract: Systems, methods, and devices for generating a secure join of database data are disclosed. A method includes determining data stored in a first account to be compared with data stored in a second account. The method includes determining a function for generating a secure join key, wherein the secure join key includes a hashed string that hashes one or more of a data entry of the first account and a data entry of the second account. The method includes providing the secure join key to the first account and/or the second account.

公开(公告)号：US10762067B2

公开(公告)日：2020-09-01

申请号：US16692927

申请日：2019-11-22

Applicant: Snowflake Inc.

Inventor： Jiaqi Yan ,  Qiuye Jin ,  Shrainik Jain ,  Stratis Viglas ,  Allison Lee

IPC: G06F17/00 ,  G06F16/21 ,  G06F11/34 ,  G06F11/07 ,  G06F16/215 ,  G06F11/30 ,  G06F16/2453

Abstract: Systems, methods, and devices for incremental feature development and workload capture in database systems are disclosed. A method includes determining a workload having one or more historical client queries to be rerun for testing the feature, wherein the feature comprises procedural logic. The method further includes executing a baseline run of the workload that does not implement the feature and executing a target run of the workload while implementing the feature. The method further includes comparing the baseline run and the target run to identify whether there is a performance regression in the target run. The method further includes, in response to identifying the performance regression, rerunning the target run to identify whether the performance regression still exists.

公开(公告)号：US20200265066A1

公开(公告)日：2020-08-20

申请号：US16860976

申请日：2020-04-28

Applicant: Snowflake Inc.

Inventor： Thierry CRUANES ,  Benoit DAGEVILLE ,  Marcin ZUKOWSKI

IPC: G06F16/27 ,  G06F9/50 ,  H04L29/08 ,  G06F9/48 ,  G06F16/2455 ,  G06F16/2453 ,  G06F16/9535 ,  G06F16/2458 ,  G06F16/23 ,  G06F16/182 ,  G06F16/951 ,  G06F16/22 ,  G06F16/21 ,  G06F16/14

Abstract: Example caching systems and methods are described. In one implementation, a method identifies multiple files used to process a query and distributes each of the multiple files to a particular execution node to execute the query. Each execution node determines whether the distributed file is stored in the execution node's cache. If the execution node determines that the file is stored in the cache, it processes the query using the cached file. If the file is not stored in the cache, the execution node retrieves the file from a remote storage device, stores the file in the execution node's cache, and processes the query using the file.

公开(公告)号：US20200257705A1

公开(公告)日：2020-08-13

申请号：US16862140

申请日：2020-04-29

Applicant: Snowflake Inc.

Inventor： Thierry CRUANES ,  Benoit DAGEVILLE ,  Florian Andreas FUNKE ,  Peter POVINEC

IPC: G06F16/28 ,  H04L12/24 ,  H04L29/08 ,  G06F16/2455

Abstract: A method for a multi-cluster warehouse includes allocating processing units as part of a data warehouse. The processing units access data within one or more databases in cloud storage resources. The method also includes providing one or more queries to each processing unit within the data warehouse. In response to the queries, each processing unit performs database operations on a particular portion of a database table. The method also includes monitoring a workload of the processing units to determine that a processing capacity of the processing units has reached a threshold processing capacity. The method also includes dynamically adding additional processing units to and removing processing units from the data warehouse as needed based on a workload of the processing units.

公开(公告)号：US10719517B1

公开(公告)日：2020-07-21

申请号：US16719218

申请日：2019-12-18

Applicant: Snowflake Inc.

Inventor： Bing Li ,  Edward Ma ,  Mingli Rui ,  Haowei Yu ,  Andong Zhan

IPC: G06F16/2455 ,  G06F16/25 ,  G06F16/28 ,  G06F16/27 ,  G06F21/62 ,  H04L29/06

Abstract: A shared database platform can interface with a cluster computing platform over a network through a connector. The data transferred over the network can include metadata result packages that can be distributed to worker nodes of the duster computing platform, which receive the metadata objects and access the result data for further processing on a staging platform, such as a scalable storage platform.

公开(公告)号：US10700927B2

公开(公告)日：2020-06-30

申请号：US15858414

申请日：2017-12-29

Applicant: Snowflake Inc.

Inventor： Vineeth Narasimhan ,  Joshua Lambert ,  Thomas Herchek ,  Ryan Elliot Hope ,  Nitish Jha ,  Rahul Jain ,  Sumeet Singh

IPC: H04L12/24 ,  H04W4/50 ,  H04L29/06 ,  H04L12/58 ,  H04L29/08 ,  H04L12/911 ,  G06F9/06 ,  G06F9/50

Abstract: A cloud extension agent can be provided on a customer premise for interfacing, via an outbound secure connection, cloud based services. The cloud extension agent can reach the cloud based services through existing firewall infrastructure, thereby providing simple, secure deployment. Furthermore, the secure connection can enable substantially real-time communication with a cloud service to provide web-based, substantially real time control or management of resources on the customer premises via the cloud extension agent.

公开(公告)号：US20200167343A1

公开(公告)日：2020-05-28

申请号：US16705533

申请日：2019-12-06

Applicant: Snowflake Inc.

Inventor： Istvan Cseri ,  Torsten Grabs ,  Benoit Dageville

IPC: G06F16/23 ,  G06F9/46

Abstract: Systems, methods, and devices for executing a task on database data in response to a trigger event are disclosed. A method includes executing a transaction on a table comprising database data, wherein executing the transaction comprises generating a new table version. The method includes, in response to the transaction being fully executed, generating a change tracking entry comprising an indication of one or more modifications made to the table by the transaction and storing the change tracking entry in a change tracking stream. The method includes executing a task on the new table version in response to a trigger event.