Snowpark is currently available for the Scala programming language for use with Snowflake accounts hosted on Amazon Web Services (AWS).
Snowpark is a new developer experience that provides an intuitive API for querying and handling data. Snowpark simplifies the process of building complex data pipelines and allows you to interact with Snowflake directly without moving data to the system where your application code runs. Snowpark has several features that distinguish it from other client libraries:
The Snowpark API provides programming language constructs for building SQL statements. For example, the API provides a
selectmethod that you can use to specify the column names to return, rather than writing
'select column_name'as a string.
Although you can still use a string to specify the SQL statement to execute, you benefit from features like intelligent code completion and type checking when you use the native language constructs provided by Snowpark.
Snowpark operations are executed lazily on the server, which reduces the amount of data transferred between your client and the Snowflake database.
The core abstraction in Snowpark is the DataFrame, which represents a set of data and provides methods to operate on that data. In your client code, you construct a DataFrame object and set it up to retrieve the data that you want to use (for example, the columns containing the data, the filter to apply to rows, etc.).
The data isn’t retrieved at the time when you construct the DataFrame object. Instead, when you are ready to retrieve the data, you can perform an action that evaluates the DataFrame objects and sends the corresponding SQL statements to the Snowflake database for execution.
You can create user-defined functions (UDFs) in your code, and Snowpark can push your code to the server, where the code can operate on the data.
You can write functions in the same language that you use to write your client code (for example, by using anonymous functions in Scala). To use these functions to process data in the Snowflake database, you define and call user-defined functions (UDFs) in your custom code.
Snowpark automatically pushes the custom code for UDFs to the Snowflake database. When you call the UDF in your client code, your custom code is executed on the server (where the data is). You don’t need to transfer the data to your client in order to execute the function on the data.
- Setting Up Your Development Environment for Snowpark
- Creating a Session for Snowpark
- Working with DataFrames in Snowpark
- Creating User-Defined Functions (UDFs) for DataFrames
- Calling Functions and Stored Procedures in Snowpark
- A Simple Example of Using Snowpark
- Analyzing Queries and Troubleshooting with Snowpark
- Snowpark API Reference
- Changes to the Snowpark API