公开(公告)号：US20240020298A1

公开(公告)日：2024-01-18

申请号：US18477834

申请日：2023-09-29

Applicant: Snowflake Inc.

Inventor： Khaled Yagoub ,  Wumengjian Zhu ,  Benoit Dageville ,  William Waddington

IPC: G06F16/23 ,  G06F16/28 ,  G06F11/14 ,  G06F16/22

CPC classification number: G06F16/2379 ,  G06F16/283 ,  G06F11/1458 ,  G06F16/221

Abstract: The subject technology serializes, by at least one hardware processor, non-primary key data of column-organized data into compressed serialized value data that is in a row-organized sequence, the compressed serialized value data compressed using at least one bitmap, the non-primary key data comprising a schema identifier, the column-organized data being stored in a columnar database system, the column-organized data comprising primary key data and the non-primary key data. The subject technology stores the compressed serialized value data in a key-value data store of a key-value database system, the key-value database system processing key-value data in a key-value format. The subject technology receives a query by the columnar database system. The subject technology deserializes a portion of the compressed serialized value data that corresponds to the query. The subject technology processes the query using the columnar database system.

公开(公告)号：US20240020295A1

公开(公告)日：2024-01-18

申请号：US18476693

申请日：2023-09-28

Applicant: Snowflake Inc.

Inventor： Thierry Cruanes ,  Benoit Dageville ,  Prasanna Rajaperumal ,  Jiaqi Yan

IPC: G06F16/23 ,  G06F16/24 ,  G06F16/27 ,  G06F16/22

CPC classification number: G06F16/2365 ,  G06F16/2393 ,  G06F16/24 ,  G06F16/278 ,  G06F16/2282

Abstract: Systems, methods, and devices for incrementally refreshing a materialized view are disclosed. A method includes generating a materialized view based on a source table. The method includes merging the source table and the materialized view to generate a merged table to identify whether an update has been executed on the source table that is not reflected in the materialized view. The method includes, in response to detecting an update made to the source table that is not reflected in the materialized view, applying the update to the materialized view.

公开(公告)号：US11874824B2

公开(公告)日：2024-01-16

申请号：US17933082

申请日：2022-09-17

Applicant: Snowflake Inc.

Inventor： Benoit Dageville ,  Johan Harjono ,  Kunal Prafulla Nabar ,  Steven James Pelley

IPC: G06F16/24 ,  G06F16/23 ,  G06F16/2455

CPC classification number: G06F16/2365 ,  G06F16/2455

Abstract: Systems, methods, and devices for retrying a query. A method includes receiving a query directed to database data and assigning execution of the query to one or more execution nodes of an execution platform, the one or more execution nodes configured to execute the query on a first version of a database platform. The method includes determining that execution of the query was unsuccessful. The method includes assigning a first retry execution of the query to the one or more execution nodes of the execution platform and determining whether a regression or an intermittent fault caused the execution of the query to be unsuccessful based at least in part on whether the first retry execution of the query was successful or unsuccessful.

公开(公告)号：US11841849B2

公开(公告)日：2023-12-12

申请号：US17812878

申请日：2022-07-15

Applicant: Snowflake Inc.

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

IPC: G06F16/20 ,  G06F16/242 ,  G06F3/06 ,  G06F16/23 ,  G06F16/16 ,  G06F16/25 ,  G06F9/54 ,  G06F16/22 ,  G06F16/2455

CPC classification number: G06F16/2423 ,  G06F3/0605 ,  G06F3/067 ,  G06F3/0644 ,  G06F3/0653 ,  G06F9/542 ,  G06F16/164 ,  G06F16/2282 ,  G06F16/2358 ,  G06F16/2393 ,  G06F16/24557 ,  G06F16/256

Abstract: In an embodiment, a database platform receives a query that is directed at least in part to external data in an external table stored on a data storage platform that is external to the database platform. The external table includes a plurality of partitions. The database platform identifies, from external-table metadata, a subset of the plurality of partitions of the external table as including data that potentially satisfies the query. The external-table metadata is stored by the database platform. The database platform identifies data that satisfies the query by scanning the identified subset of the partitions, and responds to the query at least in part with the identified data that satisfies the query.

公开(公告)号：US11809451B2

公开(公告)日：2023-11-07

申请号：US14518971

申请日：2014-10-20

Applicant: Snowflake Inc.

Inventor： Benoit Dageville ,  Thierry Cruanes ,  Marcin Zukowski

IPC: G06F16/27 ,  G06F9/48 ,  G06F9/50 ,  G06F16/14 ,  G06F16/182 ,  G06F16/21 ,  G06F16/22 ,  G06F16/23 ,  G06F16/2453 ,  G06F16/2455 ,  G06F16/951 ,  G06F16/2458 ,  G06F16/9535 ,  H04L67/568 ,  G06F16/28 ,  G06F16/25 ,  A61F5/56 ,  G06F16/9538 ,  H04L67/1095 ,  H04L67/1097

CPC classification number: G06F16/273 ,  A61F5/566 ,  G06F9/4881 ,  G06F9/5016 ,  G06F9/5044 ,  G06F9/5083 ,  G06F9/5088 ,  G06F16/148 ,  G06F16/1827 ,  G06F16/211 ,  G06F16/221 ,  G06F16/2365 ,  G06F16/2456 ,  G06F16/2471 ,  G06F16/24532 ,  G06F16/24545 ,  G06F16/24552 ,  G06F16/254 ,  G06F16/27 ,  G06F16/283 ,  G06F16/951 ,  G06F16/9535 ,  G06F16/9538 ,  H04L67/1095 ,  H04L67/1097 ,  H04L67/568

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.

公开(公告)号：US11782950B2

公开(公告)日：2023-10-10

申请号：US17463357

申请日：2021-08-31

Applicant: SNOWFLAKE INC.

Inventor： Benoit Dageville ,  Thierry Cruanes ,  Marcin Zukowski

IPC: G06F15/167 ,  G06F16/27 ,  G06F9/50 ,  G06F16/14 ,  G06F16/21 ,  G06F16/22 ,  G06F16/951 ,  G06F16/182 ,  G06F16/23 ,  G06F16/2455 ,  G06F16/2458 ,  G06F16/9535 ,  G06F16/2453 ,  G06F9/48 ,  H04L67/1095 ,  H04L67/568 ,  H04L67/1097

CPC classification number: G06F16/27 ,  G06F9/4881 ,  G06F9/5016 ,  G06F9/5044 ,  G06F9/5083 ,  G06F9/5088 ,  G06F16/148 ,  G06F16/1827 ,  G06F16/211 ,  G06F16/221 ,  G06F16/2365 ,  G06F16/2456 ,  G06F16/2471 ,  G06F16/24532 ,  G06F16/24545 ,  G06F16/24552 ,  G06F16/951 ,  G06F16/9535 ,  H04L67/1095 ,  H04L67/1097 ,  H04L67/2842

Abstract: Example resource management systems and methods are described. In one implementation, a resource manager is configured to manage data processing tasks associated with multiple data elements. An execution platform is coupled to the resource manager and includes multiple execution nodes configured to store data retrieved from multiple remote storage devices. Each execution node includes a cache and a processor, where the cache and processor are independent of the remote storage devices. A metadata manager is configured to access metadata associated with at least a portion of the multiple data elements.

公开(公告)号：US20230316348A1

公开(公告)日：2023-10-05

申请号：US17710598

申请日：2022-03-31

Applicant: Snowflake Inc.

Inventor： Benoit Dageville ,  Sameer Deshpande ,  Eric Dorf ,  Subramanian Muralidhar ,  Chao Ren ,  Dangfu Wang

IPC: G06Q30/04 ,  G06Q20/14 ,  G06F9/54 ,  G06F16/25

CPC classification number: G06Q30/04 ,  G06Q20/145 ,  G06F9/547 ,  G06F16/256

Abstract: Embodiments of the present disclosure describe techniques for monitoring usage of data listings and pricing data listings based thereon. Metadata comprising a pricing plan may be added to a data listing to generate a monetized data listing. The monetized data listing may be imported to the consumer account. The usage data of the monetized data listing and listing data of the monetized data listing may be exported to a data warehousing and analysis module. A usage level for a set of jobs processed using the monetized data listing during a current incremental interval of a current billing interval may be calculated and combined with a usage level of all previous incremental intervals of the current billing interval to generate a cumulative usage record. An invoice for the billing interval may be generated based on the cumulative usage record.

公开(公告)号：US11755311B1

公开(公告)日：2023-09-12

申请号：US18169823

申请日：2023-02-15

Applicant: Snowflake Inc.

Inventor： Damien Carru ,  Benoit Dageville ,  Unmesh Jagtap ,  Subramanian Muralidhar ,  Jan Michael Timmerman

IPC: G06F8/65 ,  G06F16/21

CPC classification number: G06F8/65 ,  G06F16/219

Abstract: A versioned schema of a data platform. A process of maintaining a call stack of executing objects of an application package having a versioned schema includes calling, by a first procedure executed by one or more processors, a second procedure of a versioned application instance, and determining, by the first procedure, a version of the second procedure based on a call context. In response to determining that the version of the second procedure is not in the call context, the first procedure determines a current version of the versioned application package adds the current version to the call context as the version of the second procedure.

公开(公告)号：US11750661B1

公开(公告)日：2023-09-05

申请号：US17934899

申请日：2022-09-23

Applicant: Snowflake Inc.

Inventor： Damien Carru ,  Jeremy Yujui Chen ,  Timothy S. Conkling ,  Thierry Cruanes ,  Benoit Dageville ,  Unmesh Jagtap ,  William A. Pugh ,  Shrikant Ravindra Shanbhag ,  Xu Xu

IPC: H04L9/40 ,  G06F16/955

CPC classification number: H04L63/20 ,  G06F16/955 ,  H04L63/102

Abstract: A data platform for managing an application as a first-class database object. The data platform includes at least one processor and a memory storing instructions that cause the at least one processor to perform operations including detecting a data request from a browser for a data object located on the data platform, executing a stored procedure, the stored procedure containing instructions that cause the at least one processor to perform additional operations including instantiating a User Defined Function (UDF) server, an application engine, and the application within a security context of the data platform based on a security policy determined by an owner of the data object. The data platform then communicates with the browser using the application engine as a proxy server.

公开(公告)号：US11743324B2

公开(公告)日：2023-08-29

申请号：US17940436

申请日：2022-09-08

Applicant: SNOWFLAKE INC.

Inventor： Pui Kei Johnston Chu ,  Benoit Dageville ,  Matthew Glickman ,  Christian Kleinerman ,  Prasanna Krishnan ,  Justin Langseth

IPC: G06F15/173 ,  H04L67/10 ,  H04L9/40 ,  H04L41/50 ,  G06F16/23 ,  G06F21/62 ,  H04L67/1097 ,  H04L67/51 ,  H04L67/53

CPC classification number: H04L67/10 ,  G06F16/2379 ,  G06F21/6272 ,  H04L41/5096 ,  H04L63/0272 ,  H04L63/10 ,  H04L63/101 ,  H04L67/1097 ,  H04L67/51 ,  H04L67/53

Abstract: Sharing data in a data exchange across multiple cloud computing platforms and/or cloud computing platform regions is described. An example method can include generating a consumer account corresponding to a first cloud entity and receiving, by the first cloud entity, a copy of a data set from a provider account corresponding to a second cloud computing entity, wherein the first cloud computing entity and the second cloud computing entity represent different regions of a cloud computing platform. The method may also include accessing, by the consumer account, the copy of the data set.