Snowpark Checkpoints Framework API Reference¶
The Snowpark Checkpoints Framework is a Python package that provides an integrated solution for validating the compatibility between PySpark and migrated Snowpark workloads.
It lets you collect information about PySpark dataframes using a collector mechanism. The collected information is then used to validate the generated Snowpark dataframes to ensure that they are equivalent to the original PySpark dataframes.
- Snowpark Checkpoints Collectors API
- Snowpark Checkpoints Configuration API
- Snowpark Checkpoints Hypothesis API
- Snowpark Checkpoints Validators API
- snowflake.snowpark_checkpoints
- snowflake.snowpark_checkpoints.check_with_spark
- snowflake.snowpark_checkpoints.check_dataframe_schema
- snowflake.snowpark_checkpoints.check_output_schema
- snowflake.snowpark_checkpoints.check_input_schema
- snowflake.snowpark_checkpoints.validate_dataframe_checkpoint
- snowflake.snowpark_checkpoints.SnowparkJobContext
- snowflake.snowpark_checkpoints.CheckpointMode
- snowflake.snowpark_checkpoints