-
公开(公告)号:US11675784B2
公开(公告)日:2023-06-13
申请号:US17823132
申请日:2022-08-30
Applicant: Snowflake Inc.
Inventor: Srilakshmi Chintala , Istvan Cseri , Albert L. Hu , Isaac Kunen , Nitya Kumar Sharma , Igor Zinkovsky
IPC: G06F16/22 , G06F16/2458 , G06F16/245 , G06F16/958 , H04L9/40
CPC classification number: G06F16/245 , G06F16/2282 , G06F16/2471 , G06F16/986 , H04L63/0281 , H04L63/0846
Abstract: A query referencing an external table function provided by a remote software component is received. Requests to execute the external table function on input data are sent to a proxy service. A first request includes a batch of input rows from the input data. A first response to the first request received from the proxy service includes a first portion of result data and a pagination token. The pagination token indicates that at least a second portion of the result data corresponding to the first batch of input rows is to be obtained from the remote software component. Based on the pagination token, a second request is sent to obtain the second portion of the result data. One or more responses are received from the proxy service that comprise at least the second portion of the result data. The result data is processed according to the query.
-
公开(公告)号:US20230097756A1
公开(公告)日:2023-03-30
申请号:US18063253
申请日:2022-12-08
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/2455 , G06F16/908 , G06F16/955 , G06F16/22
Abstract: A method includes decoding, by at least one hardware processor, a request for a user-defined function (UDF). The request includes a reference to one or more files. The method further includes generating, by the at least one hardware processor, the UDF based on the request. The UDF includes a file reference object with file path information corresponding to the reference. The file path information identifies a file path to the one or more files. A UDF call into the UDF is detected. The UDF call specifies the file path information. The UDF call is processed to generate result data using the one or more files.
-
公开(公告)号:US20220129335A1
公开(公告)日:2022-04-28
申请号:US17572205
申请日:2022-01-10
Applicant: Snowflake Inc.
Inventor: Istvan Cseri , Isaac Kunen , Igor Zinkovsky
IPC: G06F9/54 , H04L67/565 , G06F16/242
Abstract: A query referencing a function associated with a remote software component is received by a network-based data warehouse system. Temporary security credentials corresponding to a role at a cloud computing service platform are obtained. The role has permission to send calls to a web endpoint corresponding to the remote software component. A request comprising input data and electronically signed using the temporary security credentials is sent to a web Application Programming Interface (API) management system of the cloud computing service platform. The request, when received by the web API management system, causes the web API management system to invoke external functionality provided by the remote software component at the web endpoint with respect to the input data. A response comprising a result of invoking the external functionality is received from the web API management system, and the result data is processed according to the query.
-
公开(公告)号:US11216421B2
公开(公告)日:2022-01-04
申请号:US17345422
申请日:2021-06-11
Applicant: Snowflake Inc.
Inventor: Istvan Cseri , Tyler Jones , Dinesh Chandrakant Kulkarni , Igor Zinkovsky
IPC: G06F16/18 , G06F16/182 , G06F16/2453 , G06F16/2455 , G06F16/23
Abstract: The subject technology determines, using a stream object provided by a network-based database system separate from an external system, a set of offsets of each shard of a set of shards, the set of offsets being determined by executing a user defined function (UDF) included in the stream object, the stream object and the UDF being implemented in a particular programming language different than a database query language. The subject technology identifies an operation to perform on the set of shards. The subject technology, based on the set of shards and the set of offsets, performs, using the UDF included in the stream object, the operation on an external data source hosted by the external system. The subject technology increments a property indicating a different version of the stream object after performing the operation on the external data source, the property being included in the stream object.
-
公开(公告)号:US20210240557A1
公开(公告)日:2021-08-05
申请号:US17238558
申请日:2021-04-23
Applicant: Snowflake Inc.
Inventor: Istvan Cseri , Isaac Kunen , Igor Zinkovsky
IPC: G06F9/54 , H04L29/06 , H04L29/08 , G06F16/242
Abstract: A query referencing a function associated with a remote software component is received by a network-based data warehouse system. Temporary security credentials corresponding to a role at a cloud computing service platform are obtained. The role has permission to send calls to a web endpoint corresponding to the remote software component. A request comprising input data and electronically signed using the temporary security credentials is sent to a web Application Programming Interface (API) management system of the cloud computing service platform. The request, when received by the web API management system, causes the web API management system to invoke external functionality provided by the remote software component at the web endpoint with respect to the input data. A response comprising a result of invoking the external functionality is received from the web API management system, and the result data is processed according to the query.
-
公开(公告)号:US20210216385A1
公开(公告)日:2021-07-15
申请号:US17219858
申请日:2021-03-31
Applicant: Snowflake Inc.
Inventor: Istvan Cseri , Isaac Kunen , Igor Zinkovsky
IPC: G06F9/54 , H04L29/08 , H04L29/06 , G06F16/242
Abstract: A query referencing a function associated with a remote software component is received by a network-based data warehouse system. Temporary security credentials corresponding to a role at a cloud computing service platform are obtained. The role has permission to send calls to a web endpoint corresponding to the remote software component. A request comprising input data and electronically signed using the temporary security credentials is sent to a web Application Programming Interface (API) management system of the cloud computing service platform. The request, when received by the web API management system, causes the web API management system to invoke external functionality provided by the remote software component at the web endpoint with respect to the input data. A response comprising a result of invoking the external functionality is received from the web API management system, and the result data is processed according to the query.
-
公开(公告)号:US10997005B1
公开(公告)日:2021-05-04
申请号:US17028466
申请日:2020-09-22
Applicant: Snowflake Inc.
Inventor: Istvan Cseri , Isaac Kunen , Igor Zinkovsky
IPC: G06F9/44 , G06F9/54 , G06F16/242 , H04L29/06 , H04L29/08
Abstract: A query referencing a function associated with a remote software component is received by a network-based data warehouse system. Temporary security credentials corresponding to a role at a cloud computing service platform are obtained. The role has permission to send calls to a web endpoint corresponding to the remote software component. A request comprising input data and electronically signed using the temporary security credentials is sent to a web Application Programming Interface (API) management system of the cloud computing service platform. The request, when received by the web API management system, causes the web API management system to invoke external functionality provided by the remote software component at the web endpoint with respect to the input data. A response comprising a result of invoking the external functionality is received from the web API management system, and the result data is processed according to the query.
-
公开(公告)号:US20210124633A1
公开(公告)日:2021-04-29
申请号:US17028466
申请日:2020-09-22
Applicant: Snowflake Inc.
Inventor: Istvan Cseri , Isaac Kunen , Igor Zinkovsky
IPC: G06F9/54 , G06F16/242 , H04L29/06 , H04L29/08
Abstract: A query referencing a function associated with a remote software component is received by a network-based data warehouse system. Temporary security credentials corresponding to a role at a cloud computing service platform are obtained. The role has permission to send calls to a web endpoint corresponding to the remote software component. A request comprising input data and electronically signed using the temporary security credentials is sent to a web Application Programming Interface (API) management system of the cloud computing service platform. The request, when received by the web API management system, causes the web API management system to invoke external functionality provided by the remote software component at the web endpoint with respect to the input data. A response comprising a result of invoking the external functionality is received from the web API management system, and the result data is processed according to the query.
-
-
-
-
-
-
-