公开(公告)号：US11948025B2

公开(公告)日：2024-04-02

申请号：US18326905

申请日：2023-05-31

Applicant: Snowflake Inc.

Inventor： Isaac Kunen ,  Srinath Shankar ,  Zihan Li ,  Khushboo Bhatia ,  Edward Ma

IPC: G06F9/54 ,  G06F16/2455 ,  G06F16/28 ,  G06F21/53

CPC classification number: G06F9/547 ,  G06F16/2455 ,  G06F16/289 ,  G06F21/53

Abstract: Methods, systems, and computer programs are presented for providing stored procedures stored within a database to invoke specified functionality in a cloud data platform. A response to a database query is received at a compute node of a cloud data platform. A java database connectivity (JDBC) instance executing within a sandbox process converts the response into a remote procedure call. The remote procedure call is provided to a stored procedure executing within the sandbox process as the response to the database query.

公开(公告)号：US20220413819A1

公开(公告)日：2022-12-29

申请号：US17823175

申请日：2022-08-30

Applicant: Snowflake Inc.

Inventor： Istvan Cseri ,  Isaac Kunen ,  Bing Li ,  Edward Ma ,  Srinath Shankar

IPC: G06F8/51 ,  G06F16/2452 ,  G06F16/2455 ,  G06F16/242 ,  G06F16/901 ,  G06F16/27

Abstract: The subject technology generates, by executing first code in a first programming language, a resilient distributed dataset (RDD). The subject technology generates, by executing the first code in the first programming language, a second RDD based on the generated RDD. The subject technology generates, by executing the first code in the first programming language, a directed acyclic graph (DAG) including the generated RDD and the generated second RDD. The subject technology serializes the DAG. The subject technology generates a database table based on the serialized DAG. The subject technology converts the first code to second code in a second programming language different than the first programming language, and at least one database query in a second format different than the first programming language. The subject technology sends the converted first code and the at least one database query to a database system for execution.

公开(公告)号：US11347485B1

公开(公告)日：2022-05-31

申请号：US17389937

申请日：2021-07-30

Applicant: Snowflake Inc.

Inventor： Elliott Brossard ,  Istvan Cseri ,  Derek Denny-Brown ,  Filip Drozdowski ,  Isaac Kunen ,  Edward Ma

IPC: G06F9/44 ,  G06F8/41 ,  G06F16/22 ,  G06F8/30

Abstract: A system comprises at least one hardware processor and a memory storing instructions. When executed, the instructions cause the at least one hardware processor to perform operations comprising receiving, in a compiling process, a request to create a Java user-defined table function (Java UDTF), the Java UDTF including code related to receiving one or more input tables and transforming the one or more input tables to an output table; verifying a construct of the Java UDTF in the request is correct; and compiling to generate execution code that includes the Java UDTF when the construct of the Java UDTF is correct.

公开(公告)号：US11113151B1

公开(公告)日：2021-09-07

申请号：US17218277

申请日：2021-03-31

Applicant: Snowflake Inc.

Inventor： Bing Li ,  Zihan Li ,  Edward Ma ,  Mingli Rui ,  Srinath Shankar

IPC: G06F16/14 ,  G06F11/14 ,  G06F16/215 ,  G06F9/50 ,  G06F16/28

Abstract: A shared database platform can interface with a cluster computing platform over a network through a database connector and one or more cluster connectors. The data transferred over the network can include telemetry metadata that can be distributed to execution nodes of the cluster computing platform for generation and transmission of cluster data to the shared database platform.

公开(公告)号：US11423081B1

公开(公告)日：2022-08-23

申请号：US17390969

申请日：2021-08-01

Applicant: Snowflake Inc.

Inventor： Elliott Brossard ,  Sukruth Komarla Sukumar ,  Isaac Kunen ,  Ju-Yi Kuo ,  Jonathan Leang ,  Edward Ma ,  Schuyler James Manchester ,  Polita Paulus ,  Saurin Shah ,  Igor Zinkovsky

IPC: G06F16/00 ,  G06F16/901 ,  G06F16/955 ,  G06F16/2455 ,  G06F16/22 ,  G06F16/908

Abstract: A file access system for user defined functions (UDFs) can be implemented on a distributed database system. The system can store UDF signatures and interfaces (e.g., classes, sub-classes) that can be called by other users. Upon a UDF being called, one or more interface objects (e.g., InputStream) can be created and requests transferred to a execution node via a network channel. The execution node can implement multiple threads that are authorized and download file data from a staging location (e.g., internal stage, external stage) concurrently.

公开(公告)号：US20220237231A1

公开(公告)日：2022-07-28

申请号：US17657548

申请日：2022-03-31

Applicant: Snowflake Inc.

Inventor： Elliott Brossard ,  Sukruth Komarla Sukumar ,  Isaac Kunen ,  Ju-yi Kuo ,  Jonathan Lee Leang ,  Edward Ma ,  Schuyler James Manchester ,  Polita Paulus ,  Saurin Shah ,  Igor Zinkovsky

IPC: G06F16/901 ,  G06F16/955 ,  G06F16/2455 ,  G06F16/22 ,  G06F16/908

Abstract: A file access system for user defined functions (UDFs) can be implemented on a distributed database system. The system can store UDF interfaces and file reference objects that can be called by other users. Upon a UDF being called, files on a stage, one or more interface objects (e.g., InputStream), and file reference objects can be implemented by execution nodes of the distributed database system. The execution nodes can implement multiple threads that are authenticated and can download file data from a staging location concurrently.

公开(公告)号：US11216322B1

公开(公告)日：2022-01-04

申请号：US17390930

申请日：2021-07-31

Applicant: Snowflake Inc.

Inventor： Isaac Kunen ,  Srinath Shankar ,  Zihan Li ,  Khushboo Bhatia ,  Edward Ma

IPC: G06F9/54 ,  G06F16/24 ,  G06F16/28 ,  G06F21/53 ,  G06F16/2455

Abstract: Disclosed are systems, methods, and non-transitory computer-readable media for a providing stored procedures in a network-based database system. A database system executes a stored procedure within a sandbox process. The sandbox process separates the stored procedure from the other services and processes of the database system and may also limit the resources (e.g., storage, memory, etc.) and functionality available to the stored procedure. Stored procedures are commonly designed to execute database queries that are processed by other components of the database system. To provide for secure communication between the stored procedure and the other components of the database system, the sandbox process is loaded with java database connectivity (JDBC) libraries (e.g., JDBC instance) that is modified to limit the communication abilities of the stored procedure.

公开(公告)号：US11030046B1

公开(公告)日：2021-06-08

申请号：US17161989

申请日：2021-01-29

Applicant: Snowflake Inc.

Inventor： Bing Li ,  Zihan Li ,  Edward Ma ,  Mingli Rui ,  Srinath Shankar

IPC: G06F16/21 ,  G06F11/14 ,  G06F9/50 ,  G06F16/215 ,  G06F16/28

Abstract: A shared database platform can interface with a cluster computing platform over a network through a database connector and one or more cluster connectors. The data transferred over the network can include telemetry metadata that can be distributed to execution nodes of the cluster computing platform for generation and transmission of cluster data to the shared database platform.

公开(公告)号：US20240411812A1

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

申请号：US18808262

申请日：2024-08-19

Applicant: Snowflake Inc.

Inventor： Elliott Brossard ,  Sukruth Komarla Sukumar ,  Isaac Kunen ,  Ju-yi Kuo ,  Jonathan Lee Leang ,  Edward Ma ,  Schuyler James Manchester ,  Polita Paulus ,  Saurin Shah ,  Igor Zinkovsky

IPC: G06F16/901 ,  G06F16/22 ,  G06F16/2455 ,  G06F16/908 ,  G06F16/955

Abstract: A method to access data includes generating, by at least one hardware processor, a user-defined function (UDF). The UDF includes a file reference object corresponding to at least one file and a file operation configuration. The at least one file is retrieved based on a UDF call into the UDF. The retrieving is further based on the file reference object. A compression status of the at least one file is determined. The UDF call is processed to generate result data using the at least one file. The processing of the UDF call is based on the compression status and the file operation configuration.

公开(公告)号：US20240176763A1

公开(公告)日：2024-05-30

申请号：US18190198

申请日：2023-03-27

Applicant: Snowflake Inc.

Inventor： Elliott Brossard ,  Sukruth Komarla Sukumar ,  Isaac Kunen ,  Ju-Yi Kuo ,  Jonathan Lee Leang ,  Edward Ma ,  Schuyler James Manchester ,  Polita Paulus ,  Saurin Shah ,  Igor Zinkovsky

IPC: G06F16/182 ,  G06F9/54 ,  G06F16/13 ,  G06F16/14 ,  G06F16/176

CPC classification number: G06F16/183 ,  G06F9/547 ,  G06F16/13 ,  G06F16/148 ,  G06F16/176

Abstract: Techniques for accessing data objects using UDF streams include decoding by at least one hardware processor of a first computing node, a first request for a UDF. The first request is generated at a second computing node by one of a plurality of input streams of the UDF. A second request for one or more data objects associated with the UDF is generated at the first computing node using an execution thread assigned to the first request. An authorization of the execution thread is performed using data access rights assigned to the first request. The one or more data objects are retrieved based on the authorization in response to the second request. The one or more data objects are stored in a storage location accessible by the execution thread.