SPRKSCL1114
org.apache.spark.sql.functions.repeat
Message: org.apache.spark.sql.functions.repeat has a workaround, see documentation for more info
Category: Warning
Description
This issue appears when the SMA detects a use of the org.apache.spark.sql.functions.repeat function, which has a workaround.
Scenario
Input
Below is an example of the org.apache.spark.sql.functions.repeat
function that generates this EWI.
val df = Seq("Hello", "World").toDF("word")
val result = df.withColumn("repeated_word", repeat(col("word"), 3))
Output
The SMA adds the EWI SPRKSCL1114
to the output code to let you know that this function is not fully supported by Snowpark, but it has a workaround.
val df = Seq("Hello", "World").toDF("word")
/*EWI: SPRKSCL1114 => org.apache.spark.sql.functions.repeat has a workaround, see documentation for more info*/
val result = df.withColumn("repeated_word", repeat(col("word"), 3))
Recommended fix
As a workaround, you can convert the second argument into a column object using the com.snowflake.snowpark.functions.lit function.
val df = Seq("Hello", "World").toDF("word")
val result = df.withColumn("repeated_word", repeat(col("word"), lit(3)))
Additional recommendations
For more support, you can email us at sma-support@snowflake.com or post an issue in the SMA.
Last updated